asyncobservable.ts

'use strict';

interface AsyncSubscription {
  unsubscribeAsync(): Promise<void>;
}

interface AsyncObserver<T> {
  next(value: T): Promise<void>;
  error(error: any): Promise<void>;
  complete(): Promise<void>;
}
    
interface AsyncObservable<T> {
  subscribeAsync(observer: AsyncObserver<T>): AsyncSubscription;
  [Symbol.asyncObservable](): AsyncObservable<T>;
}
    
export function create<T>(
    factory: (observer: AsyncObserver<T>) => Promise<AsyncSubscription>): Promise<AsyncObservable> {
  // TODO: Implementation
}