UNPKG

1.2 kBJavaScriptView Raw
1"use strict";
2Object.defineProperty(exports, "__esModule", { value: true });
3var socket_1 = require("./socket");
4var logger_1 = require("./logger");
5function listen(options) {
6 var webSocket = options.webSocket, onConnection = options.onConnection;
7 var logger = options.logger || new logger_1.ConsoleLogger();
8 webSocket.onopen = function () {
9 var socket = toSocket(webSocket);
10 var connection = socket_1.createWebSocketConnection(socket, logger);
11 onConnection(connection);
12 };
13}
14exports.listen = listen;
15function toSocket(webSocket) {
16 return {
17 send: function (content) { return webSocket.send(content); },
18 onMessage: function (cb) { return webSocket.onmessage = function (event) { return cb(event.data); }; },
19 onError: function (cb) { return webSocket.onerror = function (event) {
20 if ('message' in event) {
21 cb(event.message);
22 }
23 }; },
24 onClose: function (cb) { return webSocket.onclose = function (event) { return cb(event.code, event.reason); }; },
25 dispose: function () { return webSocket.close(); }
26 };
27}
28exports.toSocket = toSocket;
29//# sourceMappingURL=connection.js.map
\No newline at end of file