class BufferToggleSubscriber extends OuterSubscriber {
constructor(destination, openings, closingSelector) {
super(destination);
- this.openings = openings;
this.closingSelector = closingSelector;
this.contexts = [];
this.add(subscribeToResult(this, openings));
this.contexts = null;
super._complete();
}
- notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) {
+ notifyNext(outerValue, innerValue) {
outerValue ? this.closeBuffer(outerValue) : this.openBuffer(innerValue);
}
notifyComplete(innerSub) {