import { Readable, Writable } from "node:stream";
declare const $streams: unique symbol;
export interface NodeOptions {
    id: string;
}
export declare class Node<InT, OutT, StreamT extends Writable | Readable = Writable | Readable> {
    static [$streams]: WeakSet<Writable | Readable>;
    protected _stream: StreamT;
    protected _queue: InT[];
    protected _size: number;
    protected _id: string;
    constructor(stream: StreamT, options?: NodeOptions);
    connect(...nodes: Node<OutT, unknown>[]): this;
    disconnect(...nodes: Node<OutT, unknown>[]): this;
    protected _write(data: InT, encoding?: NodeJS.BufferEncoding): Promise<void>;
}
export {};