source: trip-planner-front/node_modules/rxjs/internal/innerSubscribe.d.ts

Last change on this file was 6a3a178, checked in by Ema <ema_spirova@…>, 3 years ago

initial commit

  • Property mode set to 100644
File size: 2.4 KB
Line 
1/** @prettier */
2import { Subscription } from './Subscription';
3import { Subscriber } from './Subscriber';
4interface SimpleOuterSubscriberLike<T> {
5 /**
6 * A handler for inner next notifications from the inner subscription
7 * @param innerValue the value nexted by the inner producer
8 */
9 notifyNext(innerValue: T): void;
10 /**
11 * A handler for inner error notifications from the inner subscription
12 * @param err the error from the inner producer
13 */
14 notifyError(err: any): void;
15 /**
16 * A handler for inner complete notifications from the inner subscription.
17 */
18 notifyComplete(): void;
19}
20export declare class SimpleInnerSubscriber<T> extends Subscriber<T> {
21 private parent;
22 constructor(parent: SimpleOuterSubscriberLike<any>);
23 protected _next(value: T): void;
24 protected _error(error: any): void;
25 protected _complete(): void;
26}
27export declare class ComplexInnerSubscriber<T, R> extends Subscriber<R> {
28 private parent;
29 outerValue: T;
30 outerIndex: number;
31 constructor(parent: ComplexOuterSubscriber<T, R>, outerValue: T, outerIndex: number);
32 protected _next(value: R): void;
33 protected _error(error: any): void;
34 protected _complete(): void;
35}
36export declare class SimpleOuterSubscriber<T, R> extends Subscriber<T> implements SimpleOuterSubscriberLike<R> {
37 notifyNext(innerValue: R): void;
38 notifyError(err: any): void;
39 notifyComplete(): void;
40}
41/**
42 * DO NOT USE (formerly "OuterSubscriber")
43 * TODO: We want to refactor this and remove it. It is retaining values it shouldn't for long
44 * periods of time.
45 */
46export declare class ComplexOuterSubscriber<T, R> extends Subscriber<T> {
47 /**
48 * @param _outerValue Used by: bufferToggle, delayWhen, windowToggle
49 * @param innerValue Used by: subclass default, combineLatest, race, bufferToggle, windowToggle, withLatestFrom
50 * @param _outerIndex Used by: combineLatest, race, withLatestFrom
51 * @param _innerSub Used by: delayWhen
52 */
53 notifyNext(_outerValue: T, innerValue: R, _outerIndex: number, _innerSub: ComplexInnerSubscriber<T, R>): void;
54 notifyError(error: any): void;
55 /**
56 * @param _innerSub Used by: race, bufferToggle, delayWhen, windowToggle, windowWhen
57 */
58 notifyComplete(_innerSub: ComplexInnerSubscriber<T, R>): void;
59}
60export declare function innerSubscribe(result: any, innerSubscriber: Subscriber<any>): Subscription | undefined;
61export {};
Note: See TracBrowser for help on using the repository browser.