Mirror: 馃帺 A tiny but capable push & pull stream library for TypeScript and Flow
at v3.1.0 438 B view raw
1import { Source } from '../wonka_types'; 2 3export interface Subscription { 4 unsubscribe(): void; 5} 6 7export interface Observer<T> { 8 next(value: T): void; 9 error(errorValue: any): void; 10 complete(): void; 11} 12 13export interface Observable<T> { 14 subscribe(observer: Observer<T>): Subscription; 15} 16 17export const fromObservable: <T>(observable: Observable<T>) => Source<T>; 18export const toObservable: <T>(source: Source<T>) => Observable<T>;