1 |
|
2 | export declare type CleanupFunction = () => void;
|
3 | export declare type SubscriberFunction<T> = (observer: Observer<T>) => (Subscription | CleanupFunction);
|
4 | export declare class Observable<T> {
|
5 | private subscriberFunction;
|
6 | constructor(subscriberFunction: SubscriberFunction<T>);
|
7 | subscribe(observer: Observer<T>): Subscription;
|
8 | }
|
9 | export interface Observer<T> {
|
10 | next?: (value: T) => void;
|
11 | error?: (error: Error) => void;
|
12 | complete?: () => void;
|
13 | }
|
14 | export interface Subscription {
|
15 | unsubscribe: CleanupFunction;
|
16 | }
|