import { Readable } from "node:stream";
import type { MessagePort } from "node:worker_threads";
/**
 * A Readable stream that wraps a MessagePort for receiving data from a worker thread
 *
 * This provides a proper Node.js stream interface for data coming from a worker thread,
 * with proper backpressure handling through drain events.
 */
export declare class MessagePortReadable extends Readable {
    private fromWorker;
    private toWorker?;
    private ended;
    closed: boolean;
    private messageHandler?;
    private closeHandler?;
    private errorHandler?;
    constructor(fromWorker: MessagePort, toWorker?: MessagePort);
    private setupMessageListener;
    _read(): void;
    _destroy(error: Error | null, callback: (error?: Error | null) => void): void;
}
//# sourceMappingURL=MessagePortReadable.d.ts.map