1 | import { Subscription } from './subscription';
|
2 | export interface NextObserver<T> {
|
3 | next: (value: T) => void;
|
4 | error?: (err: any) => void;
|
5 | complete?: () => void;
|
6 | }
|
7 | export interface ErrorObserver<T> {
|
8 | next?: (value: T) => void;
|
9 | error: (err: any) => void;
|
10 | complete?: () => void;
|
11 | }
|
12 | export interface CompletionObserver<T> {
|
13 | next?: (value: T) => void;
|
14 | error?: (err: any) => void;
|
15 | complete: () => void;
|
16 | }
|
17 | export declare type PartialObserver<T> = NextObserver<T> | ErrorObserver<T> | CompletionObserver<T>;
|
18 | export interface NextAsyncObserver<T> {
|
19 | next: (value: T) => void | Promise<void>;
|
20 | error?: (err: any) => void | Promise<void>;
|
21 | complete?: () => void | Promise<void>;
|
22 | }
|
23 | export interface ErrorAsyncObserver<T> {
|
24 | next?: (value: T) => void | Promise<void>;
|
25 | error: (err: any) => void | Promise<void>;
|
26 | complete?: () => void | Promise<void>;
|
27 | }
|
28 | export interface CompletionAsyncObserver<T> {
|
29 | next?: (value: T) => void | Promise<void>;
|
30 | error?: (err: any) => void | Promise<void>;
|
31 | complete: () => void | Promise<void>;
|
32 | }
|
33 | export declare type PartialAsyncObserver<T> = NextAsyncObserver<T> | ErrorAsyncObserver<T> | CompletionAsyncObserver<T>;
|
34 | export interface Observer<T> {
|
35 | closed?: boolean;
|
36 | next: (value: T) => void;
|
37 | error: (err: any) => void;
|
38 | complete: () => void;
|
39 | }
|
40 | export interface Observable<T> {
|
41 | subscribe: (observer: Observer<T>) => Subscription;
|
42 | }
|