1 | import { Observable, Observer, Subscriber } from "./Observable";
|
2 | type MaybeAsync<T> = T | PromiseLike<T>;
|
3 | type Source<T> = MaybeAsync<Observable<T>>;
|
4 | export type ConcastSourcesIterable<T> = Iterable<Source<T>>;
|
5 | export type ConcastSourcesArray<T> = Array<Source<T>>;
|
6 | export declare class Concast<T> extends Observable<T> {
|
7 | private observers;
|
8 | private sub?;
|
9 | constructor(sources: MaybeAsync<ConcastSourcesIterable<T>> | Subscriber<T>);
|
10 | private sources;
|
11 | private start;
|
12 | private deliverLastMessage;
|
13 | addObserver(observer: Observer<T>): void;
|
14 | removeObserver(observer: Observer<T>): void;
|
15 | private resolve;
|
16 | private reject;
|
17 | readonly promise: Promise<T>;
|
18 | private latest?;
|
19 | private handlers;
|
20 | private nextResultListeners;
|
21 | private notify;
|
22 | beforeNext(callback: NextResultListener): void;
|
23 | cancel: (reason: any) => void;
|
24 | }
|
25 | type NextResultListener = (method: "next" | "error" | "complete", arg?: any) => any;
|
26 | export {};
|
27 |
|
\ | No newline at end of file |