diff options
Diffstat (limited to 'node_modules/rxjs/dist/esm5/internal/observable/ConnectableObservable.js')
| -rw-r--r-- | node_modules/rxjs/dist/esm5/internal/observable/ConnectableObservable.js | 63 |
1 files changed, 63 insertions, 0 deletions
diff --git a/node_modules/rxjs/dist/esm5/internal/observable/ConnectableObservable.js b/node_modules/rxjs/dist/esm5/internal/observable/ConnectableObservable.js new file mode 100644 index 0000000..e51b47d --- /dev/null +++ b/node_modules/rxjs/dist/esm5/internal/observable/ConnectableObservable.js @@ -0,0 +1,63 @@ +import { __extends } from "tslib"; +import { Observable } from '../Observable'; +import { Subscription } from '../Subscription'; +import { refCount as higherOrderRefCount } from '../operators/refCount'; +import { createOperatorSubscriber } from '../operators/OperatorSubscriber'; +import { hasLift } from '../util/lift'; +var ConnectableObservable = (function (_super) { + __extends(ConnectableObservable, _super); + function ConnectableObservable(source, subjectFactory) { + var _this = _super.call(this) || this; + _this.source = source; + _this.subjectFactory = subjectFactory; + _this._subject = null; + _this._refCount = 0; + _this._connection = null; + if (hasLift(source)) { + _this.lift = source.lift; + } + return _this; + } + ConnectableObservable.prototype._subscribe = function (subscriber) { + return this.getSubject().subscribe(subscriber); + }; + ConnectableObservable.prototype.getSubject = function () { + var subject = this._subject; + if (!subject || subject.isStopped) { + this._subject = this.subjectFactory(); + } + return this._subject; + }; + ConnectableObservable.prototype._teardown = function () { + this._refCount = 0; + var _connection = this._connection; + this._subject = this._connection = null; + _connection === null || _connection === void 0 ? void 0 : _connection.unsubscribe(); + }; + ConnectableObservable.prototype.connect = function () { + var _this = this; + var connection = this._connection; + if (!connection) { + connection = this._connection = new Subscription(); + var subject_1 = this.getSubject(); + connection.add(this.source.subscribe(createOperatorSubscriber(subject_1, undefined, function () { + _this._teardown(); + subject_1.complete(); + }, function (err) { + _this._teardown(); + subject_1.error(err); + }, function () { return _this._teardown(); }))); + if (connection.closed) { + this._connection = null; + connection = Subscription.EMPTY; + } + } + return connection; + }; + ConnectableObservable.prototype.refCount = function () { + return higherOrderRefCount()(this); + }; + return ConnectableObservable; +}(Observable)); +export { ConnectableObservable }; +//# sourceMappingURL=ConnectableObservable.js.map
\ No newline at end of file |
