/// <reference types="node" />
import stream from 'stream';
import { Function0, TT$ } from '@upradata/util';
import { Condition } from './types';
export declare class TernaryStreamOpts<Data> {
    condition: Condition<Data>;
    stream?: stream.ReadableOptions & stream.WritableOptions;
    constructor(options: TernaryStreamOpts<Data>);
}
export declare class TernaryConditionOptions<Data> {
    private options;
    test: (data: Data) => TT$<boolean>;
    private isInit;
    constructor(options: TernaryStreamOpts<Data>);
    init(): Promise<void>;
}
export declare class TernaryForksStream<Data> extends stream.Writable {
    condition: TernaryConditionOptions<Data>;
    true: stream.Readable;
    false: stream.Readable;
    private resume;
    private initListeners;
    private hasInit;
    constructor(options: TernaryStreamOpts<Data>);
    addInitListener(listener: Function0<TT$<void>>): void;
    private emitInit;
    _write(data: Data, encoding: BufferEncoding, callback: (error?: Error | null) => void): Promise<void>;
}
export declare const ternaryFork: <Data>(options: TernaryStreamOpts<Data>) => TernaryForksStream<Data>;