···

       
13
       
13
       
 
       
export const filter: <A>(f: (value: A) => boolean) => Operator<A, A>;

     

       
14
       
14
       
 
       
export const scan: <A, B>(f: (acc: B, value: A) => B, acc: B) => Operator<A, B>;

     

       
15
       
15
       
 
       


     

       
16
       
16
       
+
       
export const mergeMap: <A, B>(f: (value: A) => Source<B>) => Operator<A, B>;

     

       
17
       
17
       
+
       
export const switchMap: <A, B>(f: (value: A) => Source<B>) => Operator<A, B>;

     

       
18
       
18
       
+
       
export const concatMap: <A, B>(f: (value: A) => Source<B>) => Operator<A, B>;

     

       
19
       
19
       
+
       


     

       
16
       
20
       
 
       
export const merge: <A>(sources: Array<Source<A>>) => Source<A>;

     

       
17
       
21
       
 
       
export const concat: <A>(sources: Array<Source<A>>) => Source<A>;

     

       
18
       
22
       
 
       
export const share: <A>(source: Source<A>) => Source<A>;

     

       
19
       
23
       
 
       
export const combine: <A, B>(a: Source<A>, b: Source<B>) => Source<[A, B]>;

     

       
20
       
24
       
 
       


     

       
25
       
25
       
+
       
export const concatAll: <A>(source: Source<Source<A>>) => Source<A>;

     

       
26
       
26
       
+
       
export const mergeAll: <A>(source: Source<Source<A>>) => Source<A>;

     

       
27
       
27
       
+
       
export const flatten: <A>(source: Source<Source<A>>) => Source<A>;

     

       
28
       
28
       
+
       


     

       
21
       
29
       
 
       
export const take: <A>(max: number) => Operator<A, A>;

     

       
22
       
30
       
 
       
export const takeLast: <A>(max: number) => Operator<A, A>;

     

       
23
       
31
       
 
       
export const takeWhile: <A>(f: (x: A) => boolean) => Operator<A, A>;

     
···

       
25
       
33
       
 
       
export const skip: <A>(max: number) => Operator<A, A>;

     

       
26
       
34
       
 
       
export const skipWhile: <A>(f: (value: A) => boolean) => Operator<A, A>;

     

       
27
       
35
       
 
       
export const skipUntil: <A>(signal: Source<any>) => Operator<A, A>;

     

       
28
       
28
       
-
       


     

       
29
       
29
       
-
       
export const flatten: <A>(source: Source<Source<A>>) => Source<A>;

     

       
30
       
36
       
 
       


     

       
31
       
37
       
 
       
export const forEach: <A>(f: (x: A) => void) => (source: Source<A>) => void;

     

       
32
       
38
       
 
       
export const subscribe: <A>(f: (x: A) => void) => (source: Source<A>) => (() => void);