import { InvokeableWithoutParam, Source, Subscriber, Subscription } from "../_core";
import { Transaction } from "../_tx";
import { EventStream } from "../EventStream";
import { Observable } from "../Observable";
export declare function makeMultiSourceStream<T>(observables: Array<Observable<T>>, ctor: MultiSourceCtor<T>): EventStream<T>;
export declare type MultiSourceCtor<T> = new (sources: Array<Source<T>>) => MultiSource<T>;
export declare abstract class MultiSource<T> implements Source<T>, Subscription, InvokeableWithoutParam {
    protected concurrency: number;
    readonly weight: number;
    protected head: MultiSourceNode<T> | null;
    protected sink: Subscriber<T>;
    protected active: boolean;
    protected ord: number;
    constructor(sources: Array<Source<T>>, concurrency: number);
    subscribe(subscriber: Subscriber<T>, order: number): Subscription;
    activate(initialNeeded: boolean): void;
    dispose(): void;
    reorder(order: number): void;
    invoke(): void;
    mNext(tx: Transaction, val: T): void;
    mError(tx: Transaction, err: Error): void;
    abstract mEnd(tx: Transaction, node: MultiSourceNode<T>): void;
}
export declare class MultiSourceNode<T> implements Subscriber<T> {
    m: MultiSource<T>;
    src: Source<T>;
    h: MultiSourceNode<T> | null;
    t: MultiSourceNode<T> | null;
    subs: Subscription;
    constructor(m: MultiSource<T>, src: Source<T>, h: MultiSourceNode<T> | null, t: MultiSourceNode<T> | null);
    subscribe(order: number): void;
    activate(initialNeeded: boolean): void;
    dispose(): void;
    next(tx: Transaction, val: T): void;
    error(tx: Transaction, err: Error): void;
    end(tx: Transaction): void;
}