1 | import { InternalListener, Operator, Stream } from '../index';
|
2 | export 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 | }
|
14 | export 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 | }
|
22 | export 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 | }
|
39 | declare let sampleCombine: SampleCombineSignature;
|
40 | export default sampleCombine;
|