import type { ISink, ITime } from '../../stream/index.js';
export declare abstract class MulticastSink<T> implements ISink<T> {
    protected sinkList: readonly ISink<T>[];
    private propagatingError;
    private deliveredErrors;
    event(time: ITime, value: T): void;
    error(time: ITime, error: Error): void;
    end(time: ITime): void;
}
/**
 * Lawful fan-in over one downstream sink: each contributor is a sub-sink, and
 * `end` forwards only when the LAST live contributor ends — one completing
 * contributor no longer terminates a sink other contributors still feed.
 * Detaching (disposal) is cancellation, not completion: it decrements the
 * live count without ever forwarding `end`. Errors stay applicative and pass
 * straight through. After the fan-in has forwarded `end`, it is closed:
 * late contributors attach inert.
 */
export declare class FanInSink<T> {
    readonly sink: ISink<T>;
    live: number;
    closed: boolean;
    constructor(sink: ISink<T>);
    attach(): FanInContributor<T>;
}
export declare class FanInContributor<T> implements ISink<T>, Disposable {
    readonly parent: FanInSink<T>;
    private done;
    constructor(parent: FanInSink<T>);
    event(time: ITime, value: T): void;
    error(time: ITime, error: unknown): void;
    end(time: ITime): void;
    [Symbol.dispose](): void;
}