diff options
Diffstat (limited to 'node_modules/rxjs/dist/esm5/internal/testing/HotObservable.js')
| -rw-r--r-- | node_modules/rxjs/dist/esm5/internal/testing/HotObservable.js | 45 |
1 files changed, 0 insertions, 45 deletions
diff --git a/node_modules/rxjs/dist/esm5/internal/testing/HotObservable.js b/node_modules/rxjs/dist/esm5/internal/testing/HotObservable.js deleted file mode 100644 index e019898..0000000 --- a/node_modules/rxjs/dist/esm5/internal/testing/HotObservable.js +++ /dev/null @@ -1,45 +0,0 @@ -import { __extends } from "tslib"; -import { Subject } from '../Subject'; -import { Subscription } from '../Subscription'; -import { SubscriptionLoggable } from './SubscriptionLoggable'; -import { applyMixins } from '../util/applyMixins'; -import { observeNotification } from '../Notification'; -var HotObservable = (function (_super) { - __extends(HotObservable, _super); - function HotObservable(messages, scheduler) { - var _this = _super.call(this) || this; - _this.messages = messages; - _this.subscriptions = []; - _this.scheduler = scheduler; - return _this; - } - HotObservable.prototype._subscribe = function (subscriber) { - var subject = this; - var index = subject.logSubscribedFrame(); - var subscription = new Subscription(); - subscription.add(new Subscription(function () { - subject.logUnsubscribedFrame(index); - })); - subscription.add(_super.prototype._subscribe.call(this, subscriber)); - return subscription; - }; - HotObservable.prototype.setup = function () { - var subject = this; - var messagesLength = subject.messages.length; - var _loop_1 = function (i) { - (function () { - var _a = subject.messages[i], notification = _a.notification, frame = _a.frame; - subject.scheduler.schedule(function () { - observeNotification(notification, subject); - }, frame); - })(); - }; - for (var i = 0; i < messagesLength; i++) { - _loop_1(i); - } - }; - return HotObservable; -}(Subject)); -export { HotObservable }; -applyMixins(HotObservable, [SubscriptionLoggable]); -//# sourceMappingURL=HotObservable.js.map
\ No newline at end of file |
