/** @prettier */ import { Subscription } from './Subscription'; import { Subscriber } from './Subscriber'; interface SimpleOuterSubscriberLike<T> { /** * A handler for inner next notifications from the inner subscription * @param innerValue the value nexted by the inner producer */ notifyNext(innerValue: T): void; /** * A handler for inner error notifications from the inner subscription * @param err the error from the inner producer */ notifyError(err: any): void; /** * A handler for inner complete notifications from the inner subscription. */ notifyComplete(): void; } export declare class SimpleInnerSubscriber<T> extends Subscriber<T> { private parent; constructor(parent: SimpleOuterSubscriberLike<any>); protected _next(value: T): void; protected _error(error: any): void; protected _complete(): void; } export declare class ComplexInnerSubscriber<T, R> extends Subscriber<R> { private parent; outerValue: T; outerIndex: number; constructor(parent: ComplexOuterSubscriber<T, R>, outerValue: T, outerIndex: number); protected _next(value: R): void; protected _error(error: any): void; protected _complete(): void; } export declare class SimpleOuterSubscriber<T, R> extends Subscriber<T> implements SimpleOuterSubscriberLike<R> { notifyNext(innerValue: R): void; notifyError(err: any): void; notifyComplete(): void; } /** * DO NOT USE (formerly "OuterSubscriber") * TODO: We want to refactor this and remove it. It is retaining values it shouldn't for long * periods of time. */ export declare class ComplexOuterSubscriber<T, R> extends Subscriber<T> { /** * @param _outerValue Used by: bufferToggle, delayWhen, windowToggle * @param innerValue Used by: subclass default, combineLatest, race, bufferToggle, windowToggle, withLatestFrom * @param _outerIndex Used by: combineLatest, race, withLatestFrom * @param _innerSub Used by: delayWhen */ notifyNext(_outerValue: T, innerValue: R, _outerIndex: number, _innerSub: ComplexInnerSubscriber<T, R>): void; notifyError(error: any): void; /** * @param _innerSub Used by: race, bufferToggle, delayWhen, windowToggle, windowWhen */ notifyComplete(_innerSub: ComplexInnerSubscriber<T, R>): void; } export declare function innerSubscribe(result: any, innerSubscriber: Subscriber<any>): Subscription | undefined; export {};
Name | Type | Size | Permission | Actions |
---|---|---|---|---|
observable | Folder | 0755 |
|
|
operators | Folder | 0755 |
|
|
scheduled | Folder | 0755 |
|
|
scheduler | Folder | 0755 |
|
|
symbol | Folder | 0755 |
|
|
testing | Folder | 0755 |
|
|
util | Folder | 0755 |
|
|
AsyncSubject.d.ts | File | 640 B | 0644 |
|
AsyncSubject.js | File | 2.17 KB | 0644 |
|
AsyncSubject.js.map | File | 1.11 KB | 0644 |
|
BehaviorSubject.d.ts | File | 597 B | 0644 |
|
BehaviorSubject.js | File | 2.01 KB | 0644 |
|
BehaviorSubject.js.map | File | 894 B | 0644 |
|
InnerSubscriber.d.ts | File | 532 B | 0644 |
|
InnerSubscriber.js | File | 1.59 KB | 0644 |
|
InnerSubscriber.js.map | File | 801 B | 0644 |
|
Notification.d.ts | File | 3.37 KB | 0644 |
|
Notification.js | File | 2.72 KB | 0644 |
|
Notification.js.map | File | 2.09 KB | 0644 |
|
Observable.d.ts | File | 5.93 KB | 0644 |
|
Observable.js | File | 3.96 KB | 0644 |
|
Observable.js.map | File | 2.98 KB | 0644 |
|
Observer.d.ts | File | 79 B | 0644 |
|
Observer.js | File | 523 B | 0644 |
|
Observer.js.map | File | 380 B | 0644 |
|
Operator.d.ts | File | 185 B | 0644 |
|
Operator.js | File | 113 B | 0644 |
|
Operator.js.map | File | 102 B | 0644 |
|
OuterSubscriber.d.ts | File | 509 B | 0644 |
|
OuterSubscriber.js | File | 1.41 KB | 0644 |
|
OuterSubscriber.js.map | File | 543 B | 0644 |
|
ReplaySubject.d.ts | File | 982 B | 0644 |
|
ReplaySubject.js | File | 4.84 KB | 0644 |
|
ReplaySubject.js.map | File | 3.4 KB | 0644 |
|
Rx.d.ts | File | 8.91 KB | 0644 |
|
Rx.js | File | 9.22 KB | 0644 |
|
Rx.js.map | File | 2.86 KB | 0644 |
|
Scheduler.d.ts | File | 2.4 KB | 0644 |
|
Scheduler.js | File | 633 B | 0644 |
|
Scheduler.js.map | File | 537 B | 0644 |
|
Subject.d.ts | File | 2.19 KB | 0644 |
|
Subject.js | File | 5.9 KB | 0644 |
|
Subject.js.map | File | 3.82 KB | 0644 |
|
SubjectSubscription.d.ts | File | 444 B | 0644 |
|
SubjectSubscription.js | File | 1.7 KB | 0644 |
|
SubjectSubscription.js.map | File | 863 B | 0644 |
|
Subscriber.d.ts | File | 3.67 KB | 0644 |
|
Subscriber.js | File | 9.04 KB | 0644 |
|
Subscriber.js.map | File | 5.86 KB | 0644 |
|
Subscription.d.ts | File | 2.72 KB | 0644 |
|
Subscription.js | File | 5.18 KB | 0644 |
|
Subscription.js.map | File | 3.75 KB | 0644 |
|
config.d.ts | File | 860 B | 0644 |
|
config.js | File | 846 B | 0644 |
|
config.js.map | File | 502 B | 0644 |
|
innerSubscribe.d.ts | File | 2.4 KB | 0644 |
|
innerSubscribe.js | File | 4.14 KB | 0644 |
|
innerSubscribe.js.map | File | 2.15 KB | 0644 |
|
types.d.ts | File | 3.17 KB | 0644 |
|
types.js | File | 110 B | 0644 |
|
types.js.map | File | 96 B | 0644 |
|