observable.ts

interface Disposable {
  dispose(): void
}

interface Observable<T> {
  subscribe(observer: Observer<T>) : Disposable 
  // OR 
  forEach(observer: Observer<T>) : Disposable
}

interface Observer<T> {
  onNext(value: T)
  onError(error: Error)
  onCompleted()
}