/**
 * @module Node Worker streams
 */
import { BaseDuplexStream } from "../BaseDuplexStream.cjs";
import type { BaseReaderArgs, BaseWriterArgs, ValidateInput } from "../BaseStream.cjs";
import { BaseReader, BaseWriter } from "../BaseStream.cjs";
export type OnMessage = (message: unknown) => void;
export type NodePort = {
    on: (event: 'message', listener: OnMessage) => void;
    postMessage: (message: unknown) => void;
};
/**
 * A readable stream over a {@link NodePort}.
 *
 * @see
 * - {@link NodeWorkerWriter} for the corresponding writable stream.
 * - The module-level documentation for more details.
 */
export declare class NodeWorkerReader<Read> extends BaseReader<Read> {
    /**
     * Constructs a new {@link NodeWorkerReader}.
     *
     * @param port - The node worker port to read from.
     * @param options - Options bag for configuring the reader.
     * @param options.validateInput - A function that validates input from the transport.
     * @param options.onEnd - A function that is called when the stream ends.
     */
    constructor(port: NodePort, { validateInput, onEnd }?: BaseReaderArgs<Read>);
}
/**
 * A writable stream over a {@link NodeWorker}.
 *
 * @see
 * - {@link NodeWorkerReader} for the corresponding readable stream.
 * - The module-level documentation for more details.
 */
export declare class NodeWorkerWriter<Write> extends BaseWriter<Write> {
    /**
     * Constructs a new {@link NodeWorkerWriter}.
     *
     * @param port - The node worker port to write to.
     * @param options - Options bag for configuring the writer.
     * @param options.name - The name of the stream, for logging purposes.
     * @param options.onEnd - A function that is called when the stream ends.
     */
    constructor(port: NodePort, { name, onEnd }?: Omit<BaseWriterArgs<Write>, 'onDispatch'>);
}
/**
 * A duplex stream over a Node worker port.
 */
export declare class NodeWorkerDuplexStream<Read, Write = Read> extends BaseDuplexStream<Read, NodeWorkerReader<Read>, Write, NodeWorkerWriter<Write>> {
    /**
     * Constructs a new {@link NodeWorkerDuplexStream}.
     *
     * @param port - The node worker port for bidirectional communication.
     * @param validateInput - A function that validates input from the transport.
     */
    constructor(port: NodePort, validateInput?: ValidateInput<Read>);
    /**
     * Creates and synchronizes a new {@link NodeWorkerDuplexStream}.
     *
     * @param port - The node worker port for bidirectional communication.
     * @param validateInput - A function that validates input from the transport.
     * @returns A synchronized duplex stream.
     */
    static make<Read, Write = Read>(port: NodePort, validateInput?: ValidateInput<Read>): Promise<NodeWorkerDuplexStream<Read, Write>>;
}
//# sourceMappingURL=NodeWorkerStream.d.cts.map