| 1 | export interface Observer<T> {
|
| 2 | next?: (value: T) => void;
|
| 3 | error?: (error: Error) => void;
|
| 4 | complete?: () => void;
|
| 5 | }
|
| 6 | export interface Observable<T> {
|
| 7 | subscribe(observer: Observer<T>): {
|
| 8 | unsubscribe: () => void;
|
| 9 | };
|
| 10 | }
|
| 11 | export declare type Callback = (value?: any) => any;
|
| 12 | export declare function observableToAsyncIterable<T>(observable: Observable<T>): AsyncIterator<T> & {
|
| 13 | [Symbol.asyncIterator]: () => AsyncIterator<T>;
|
| 14 | };
|