You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
28 lines
1.0 KiB
28 lines
1.0 KiB
import type { Observer, Subscriber } from "./Observable.js"; |
|
import { Observable } from "./Observable.js"; |
|
type MaybeAsync<T> = T | PromiseLike<T>; |
|
type Source<T> = MaybeAsync<Observable<T>>; |
|
export type ConcastSourcesIterable<T> = Iterable<Source<T>>; |
|
export type ConcastSourcesArray<T> = Array<Source<T>>; |
|
export declare class Concast<T> extends Observable<T> { |
|
private observers; |
|
private sub?; |
|
constructor(sources: MaybeAsync<ConcastSourcesIterable<T>> | Subscriber<T>); |
|
private sources; |
|
private start; |
|
private deliverLastMessage; |
|
addObserver(observer: Observer<T>): void; |
|
removeObserver(observer: Observer<T>): void; |
|
private resolve; |
|
private reject; |
|
readonly promise: Promise<T | undefined>; |
|
private latest?; |
|
private handlers; |
|
private nextResultListeners; |
|
private notify; |
|
beforeNext(callback: NextResultListener): void; |
|
cancel: (reason: any) => void; |
|
} |
|
type NextResultListener = (method: "next" | "error" | "complete", arg?: any) => any; |
|
export {}; |
|
//# sourceMappingURL=Concast.d.ts.map
|