Sha256: c076282f2eb3d6b34e1fe642ee23b2eba1658cd7c1a60b2adc32e6b44d5f7b4c
Contents?: true
Size: 742 Bytes
Versions: 49
Compression:
Stored size: 742 Bytes
Contents
import { Subscriber } from './Subscriber';
import { OuterSubscriber } from './OuterSubscriber';
/**
* We need this JSDoc comment for affecting ESDoc.
* @ignore
* @extends {Ignored}
*/
export class InnerSubscriber<T, R> extends Subscriber<R> {
private index: number = 0;
constructor(private parent: OuterSubscriber<T, R>, private outerValue: T, private outerIndex: number) {
super();
}
protected _next(value: R): void {
this.parent.notifyNext(this.outerValue, value, this.outerIndex, this.index++, this);
}
protected _error(error: any): void {
this.parent.notifyError(error, this);
this.unsubscribe();
}
protected _complete(): void {
this.parent.notifyComplete(this);
this.unsubscribe();
}
}
Version data entries
49 entries across 49 versions & 4 rubygems