Mirror: 馃帺 A tiny but capable push & pull stream library for TypeScript and Flow
at v4.0.10 659 B view raw
1export type Exn_t = Error; 2export type Internal_meth<_T, R> = () => R; 3 4export type talkbackT = 0 | 1; 5 6export type signalT<a> = 7 | ({ tag: 0 } & [(talkback: talkbackT) => void]) 8 | ({ tag: 1 } & [a]) 9 | 0; 10 11export interface observableSubscriptionT { 12 unsubscribe(): void; 13} 14 15export interface observableObserverT<a> { 16 next(value: a): void; 17 error(error: any): void; 18 complete(): void; 19} 20 21export interface observableT<a> { 22 subscribe(observer: observableObserverT<a>): observableSubscriptionT; 23} 24 25interface Callbag<I, O> { 26 (t: 0, d: Callbag<O, I>): void; 27 (t: 1, d: I): void; 28 (t: 2, d?: any): void; 29} 30 31export type callbagT<a> = Callbag<void, a>;