1 /** PURE_IMPORTS_START tslib,_.._Subject,_.._Subscriber,_.._Observable,_.._Subscription,_.._ReplaySubject PURE_IMPORTS_END */
2 import * as tslib_1 from "tslib";
3 import { Subject, AnonymousSubject } from '../../Subject';
4 import { Subscriber } from '../../Subscriber';
5 import { Observable } from '../../Observable';
6 import { Subscription } from '../../Subscription';
7 import { ReplaySubject } from '../../ReplaySubject';
8 var DEFAULT_WEBSOCKET_CONFIG = {
10 deserializer: function (e) { return JSON.parse(e.data); },
11 serializer: function (value) { return JSON.stringify(value); },
13 var WEBSOCKETSUBJECT_INVALID_ERROR_OBJECT = 'WebSocketSubject.error must be called with an object with an error code, and an optional reason: { code: number, reason: string }';
14 var WebSocketSubject = /*@__PURE__*/ (function (_super) {
15 tslib_1.__extends(WebSocketSubject, _super);
16 function WebSocketSubject(urlConfigOrSource, destination) {
17 var _this = _super.call(this) || this;
18 if (urlConfigOrSource instanceof Observable) {
19 _this.destination = destination;
20 _this.source = urlConfigOrSource;
23 var config = _this._config = tslib_1.__assign({}, DEFAULT_WEBSOCKET_CONFIG);
24 _this._output = new Subject();
25 if (typeof urlConfigOrSource === 'string') {
26 config.url = urlConfigOrSource;
29 for (var key in urlConfigOrSource) {
30 if (urlConfigOrSource.hasOwnProperty(key)) {
31 config[key] = urlConfigOrSource[key];
35 if (!config.WebSocketCtor && WebSocket) {
36 config.WebSocketCtor = WebSocket;
38 else if (!config.WebSocketCtor) {
39 throw new Error('no WebSocket constructor can be found');
41 _this.destination = new ReplaySubject();
45 WebSocketSubject.prototype.lift = function (operator) {
46 var sock = new WebSocketSubject(this._config, this.destination);
47 sock.operator = operator;
51 WebSocketSubject.prototype._resetState = function () {
54 this.destination = new ReplaySubject();
56 this._output = new Subject();
58 WebSocketSubject.prototype.multiplex = function (subMsg, unsubMsg, messageFilter) {
60 return new Observable(function (observer) {
67 var subscription = self.subscribe(function (x) {
69 if (messageFilter(x)) {
76 }, function (err) { return observer.error(err); }, function () { return observer.complete(); });
79 self.next(unsubMsg());
84 subscription.unsubscribe();
88 WebSocketSubject.prototype._connectSocket = function () {
90 var _a = this._config, WebSocketCtor = _a.WebSocketCtor, protocol = _a.protocol, url = _a.url, binaryType = _a.binaryType;
91 var observer = this._output;
95 new WebSocketCtor(url, protocol) :
96 new WebSocketCtor(url);
97 this._socket = socket;
99 this._socket.binaryType = binaryType;
106 var subscription = new Subscription(function () {
107 _this._socket = null;
108 if (socket && socket.readyState === 1) {
112 socket.onopen = function (e) {
113 var _socket = _this._socket;
119 var openObserver = _this._config.openObserver;
121 openObserver.next(e);
123 var queue = _this.destination;
124 _this.destination = Subscriber.create(function (x) {
125 if (socket.readyState === 1) {
127 var serializer = _this._config.serializer;
128 socket.send(serializer(x));
131 _this.destination.error(e);
135 var closingObserver = _this._config.closingObserver;
136 if (closingObserver) {
137 closingObserver.next(undefined);
140 socket.close(e.code, e.reason);
143 observer.error(new TypeError(WEBSOCKETSUBJECT_INVALID_ERROR_OBJECT));
147 var closingObserver = _this._config.closingObserver;
148 if (closingObserver) {
149 closingObserver.next(undefined);
154 if (queue && queue instanceof ReplaySubject) {
155 subscription.add(queue.subscribe(_this.destination));
158 socket.onerror = function (e) {
162 socket.onclose = function (e) {
164 var closeObserver = _this._config.closeObserver;
166 closeObserver.next(e);
175 socket.onmessage = function (e) {
177 var deserializer = _this._config.deserializer;
178 observer.next(deserializer(e));
185 WebSocketSubject.prototype._subscribe = function (subscriber) {
187 var source = this.source;
189 return source.subscribe(subscriber);
192 this._connectSocket();
194 this._output.subscribe(subscriber);
195 subscriber.add(function () {
196 var _socket = _this._socket;
197 if (_this._output.observers.length === 0) {
198 if (_socket && _socket.readyState === 1) {
206 WebSocketSubject.prototype.unsubscribe = function () {
207 var _socket = this._socket;
208 if (_socket && _socket.readyState === 1) {
212 _super.prototype.unsubscribe.call(this);
214 return WebSocketSubject;
215 }(AnonymousSubject));
216 export { WebSocketSubject };
217 //# sourceMappingURL=WebSocketSubject.js.map