import type { ISink, ITask, ITime } from '../types.js';
export declare function runTask(time: ITime, task: ITask): void;
export declare const propagateRunEventTask: <TSinkValue, TValue>(sink: ISink<TSinkValue>, run: (time: ITime, sink: ISink<TSinkValue>, value: TValue) => void, value: TValue) => PropagateRunEventTask<TSinkValue, TValue>;
export declare const propagateRunTask: <T>(sink: ISink<T>, run: (time: ITime, sink: ISink<T>) => void) => PropagateRunTask;
export declare const propagateEndTask: (sink: ISink<any>) => PropagateEndTask;
export declare const propagateErrorEndTask: (sink: ISink<unknown>, error: unknown) => PropagateErrorEndTask;
export declare abstract class PropagateTask<T> implements ITask, Disposable {
    readonly sink: ISink<T>;
    active: boolean;
    constructor(sink: ISink<T>);
    abstract runIfActive(time: ITime): void;
    [Symbol.dispose](): void;
    run(time: ITime): void;
    error(time: ITime, e: Error): void;
}
declare class PropagateRunEventTask<TSinkValue, TValue> extends PropagateTask<TSinkValue> {
    readonly runEvent: (time: ITime, sink: ISink<TSinkValue>, value: TValue) => void;
    readonly value: TValue;
    constructor(sink: ISink<TSinkValue>, runEvent: (time: ITime, sink: ISink<TSinkValue>, value: TValue) => void, value: TValue);
    runIfActive(time: ITime): void;
}
declare class PropagateRunTask extends PropagateTask<any> {
    readonly runEvent: (time: ITime, sink: ISink<any>) => void;
    constructor(sink: ISink<any>, runEvent: (time: ITime, sink: ISink<any>) => void);
    runIfActive(time: ITime): void;
}
declare class PropagateEndTask extends PropagateTask<any> {
    runIfActive(time: ITime): void;
}
declare class PropagateErrorEndTask extends PropagateTask<any> {
    readonly errorValue: unknown;
    constructor(sink: ISink<unknown>, errorValue: unknown);
    runIfActive(time: ITime): void;
}
export {};