UNPKG

2.26 kBTypeScriptView Raw
1import { InternalListener, Operator, Stream } from '../index';
2export interface SampleCombineSignature {
3 (): <T>(s: Stream<T>) => Stream<[T]>;
4 <T1>(s1: Stream<T1>): <T>(s: Stream<T>) => Stream<[T, T1]>;
5 <T1, T2>(s1: Stream<T1>, s2: Stream<T2>): <T>(s: Stream<T>) => Stream<[T, T1, T2]>;
6 <T1, T2, T3>(s1: Stream<T1>, s2: Stream<T2>, s3: Stream<T3>): <T>(s: Stream<T>) => Stream<[T, T1, T2, T3]>;
7 <T1, T2, T3, T4>(s1: Stream<T1>, s2: Stream<T2>, s3: Stream<T3>, s4: Stream<T4>): <T>(s: Stream<T>) => Stream<[T, T1, T2, T3, T4]>;
8 <T1, T2, T3, T4, T5>(s1: Stream<T1>, s2: Stream<T2>, s3: Stream<T3>, s4: Stream<T4>, s5: Stream<T5>): <T>(s: Stream<T>) => Stream<[T, T1, T2, T3, T4, T5]>;
9 <T1, T2, T3, T4, T5, T6>(s1: Stream<T1>, s2: Stream<T2>, s3: Stream<T3>, s4: Stream<T4>, s5: Stream<T5>, s6: Stream<T6>): <T>(s: Stream<T>) => Stream<[T, T1, T2, T3, T4, T5, T6]>;
10 <T1, T2, T3, T4, T5, T6, T7>(s1: Stream<T1>, s2: Stream<T2>, s3: Stream<T3>, s4: Stream<T4>, s5: Stream<T5>, s6: Stream<T6>, s7: Stream<T7>): <T>(s: Stream<T>) => Stream<[T, T1, T2, T3, T4, T5, T6, T7]>;
11 <T1, T2, T3, T4, T5, T6, T7, T8>(s1: Stream<T1>, s2: Stream<T2>, s3: Stream<T3>, s4: Stream<T4>, s5: Stream<T5>, s6: Stream<T6>, s7: Stream<T7>, s8: Stream<T8>): <T>(s: Stream<T>) => Stream<[T, T1, T2, T3, T4, T5, T6, T7, T8]>;
12 (...streams: Array<Stream<any>>): (s: Stream<any>) => Stream<Array<any>>;
13}
14export declare class SampleCombineListener<T> implements InternalListener<T> {
15 private i;
16 private p;
17 constructor(i: number, p: SampleCombineOperator<any>);
18 _n(t: T): void;
19 _e(err: any): void;
20 _c(): void;
21}
22export declare class SampleCombineOperator<T> implements Operator<T, Array<any>> {
23 type: string;
24 ins: Stream<T>;
25 others: Array<Stream<any>>;
26 out: Stream<Array<any>>;
27 ils: Array<SampleCombineListener<any>>;
28 Nn: number;
29 vals: Array<any>;
30 constructor(ins: Stream<T>, streams: Array<Stream<any>>);
31 _start(out: Stream<Array<any>>): void;
32 _stop(): void;
33 _n(t: T): void;
34 _e(err: any): void;
35 _c(): void;
36 up(t: any, i: number): void;
37 down(i: number, l: SampleCombineListener<any>): void;
38}
39declare let sampleCombine: SampleCombineSignature;
40export default sampleCombine;