import { Source, Subscriber, Subscription } from "./_core";
import { Transaction } from "./_tx";
export declare abstract class Dispatcher<T> implements Subscriber<T>, Source<T> {
    protected source: Source<T>;
    readonly weight: number;
    protected sink: Subscriber<T>;
    protected subs: Subscription;
    protected ord: number;
    protected active: boolean;
    protected msc: MulticastSubscriber<T>;
    constructor(source: Source<T>);
    subscribe(subscriber: Subscriber<T>, order: number): Subscription;
    activate(subscriber: Subscriber<T>, initialNeeded: boolean): void;
    dispose(node: MCSNode<T>): void;
    reorder(order: number): void;
    next(tx: Transaction, val: T): void;
    error(tx: Transaction, err: Error): void;
    end(tx: Transaction): void;
    protected removeNode(node: MCSNode<T>): {
        order: number;
        next: Subscriber<T>;
    };
    protected reorderAfterRemoval(order: number): void;
    protected firstSubscribe(subscriber: Subscriber<T>, order: number): Subscription;
    protected lateSubscribe(subscriber: Subscriber<T>, order: number): Subscription;
    private makeSubs;
}
declare class MulticastSubscriber<T> implements Subscriber<T> {
    private h;
    constructor(head: MCSNode<T>);
    add(node: MCSNode<T>): void;
    removeReturnMaxOrder(node: MCSNode<T>): {
        order: number;
        next: Subscriber<T>;
    };
    removeReturnMinOrder(node: MCSNode<T>): {
        order: number;
        next: Subscriber<T>;
    };
    next(tx: Transaction, val: T): void;
    error(tx: Transaction, err: Error): void;
    end(tx: Transaction): void;
    private remove;
}
export interface MCSNode<T> {
    s: Subscriber<T>;
    o: number;
    a: boolean;
    h: MCSNode<T> | null;
    t: MCSNode<T> | null;
}
export {};