| 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 type Callback = (value?: any) => any;
|
| 12 | export declare function observableToAsyncIterable<T>(observable: Observable<T>): AsyncIterableIterator<T>;
|