observableToAsyncIterable.d.ts 399 B

123456789101112
  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>): AsyncIterableIterator<T>;