/
eb
/
Surf
Обзор
Документация
Войти
/
eb
/
Surf
Код
Запросы
0
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
master
node_modules/rxjs/src/InnerSubscriber.ts
29 строк
742 B
EvgeniyBudaev
Initial commit
17 фев 2020, 09:02
17 фев 2020, 09:02
bb6f06f
Код
Авторство
О чём код?
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(); } }