import { JobConsole } from './job_console.ts';
import { Channel } from './types.ts';
/** Route a shell's piped channels through the shared bounded byte pipe. */
export declare class PipeConsole extends JobConsole {
    private readonly pipeStderr;
    private readonly pipe;
    private muted;
    constructor(pipeStderr?: boolean, bufferBytes?: number);
    emit(channel: Channel, data: Uint8Array): Promise<void>;
    drain(): Promise<void>;
    get closedReader(): boolean;
    end(error?: unknown): void;
    /**
     * End the reader's stream here and drop what is piped after, unrefused: a
     * stopped JS run goes on past its abort, where a stopped process writes
     * nothing more, and a refused write would end it as a broken pipe instead.
     */
    mute(): void;
    closeReader(): void;
    release(): void;
    stream(): AsyncGenerator<Uint8Array>;
}
//# sourceMappingURL=pipe.d.ts.map