})();
Object.defineProperty(exports, "__esModule", { value: true });
var Subject_1 = require("../Subject");
-var OuterSubscriber_1 = require("../OuterSubscriber");
-var subscribeToResult_1 = require("../util/subscribeToResult");
+var innerSubscribe_1 = require("../innerSubscribe");
function window(windowBoundaries) {
return function windowOperatorFunction(source) {
return source.lift(new WindowOperator(windowBoundaries));
var windowSubscriber = new WindowSubscriber(subscriber);
var sourceSubscription = source.subscribe(windowSubscriber);
if (!sourceSubscription.closed) {
- windowSubscriber.add(subscribeToResult_1.subscribeToResult(windowSubscriber, this.windowBoundaries));
+ windowSubscriber.add(innerSubscribe_1.innerSubscribe(this.windowBoundaries, new innerSubscribe_1.SimpleInnerSubscriber(windowSubscriber)));
}
return sourceSubscription;
};
destination.next(_this.window);
return _this;
}
- WindowSubscriber.prototype.notifyNext = function (outerValue, innerValue, outerIndex, innerIndex, innerSub) {
+ WindowSubscriber.prototype.notifyNext = function () {
this.openWindow();
};
- WindowSubscriber.prototype.notifyError = function (error, innerSub) {
+ WindowSubscriber.prototype.notifyError = function (error) {
this._error(error);
};
- WindowSubscriber.prototype.notifyComplete = function (innerSub) {
+ WindowSubscriber.prototype.notifyComplete = function () {
this._complete();
};
WindowSubscriber.prototype._next = function (value) {
destination.next(newWindow);
};
return WindowSubscriber;
-}(OuterSubscriber_1.OuterSubscriber));
+}(innerSubscribe_1.SimpleOuterSubscriber));
//# sourceMappingURL=window.js.map
\ No newline at end of file