/// <reference types="node" />
/// <reference types="node" />
import * as streams from 'stream';
export interface PbStream {
    writeLP(input: Uint8Array): void;
    readLP(): Promise<Uint8Array>;
    unwrap(): streams.Duplex;
}
export declare class PbStreamImpl extends streams.Duplex implements PbStream {
    private readonly ringBuffer;
    private readonly receiveBuffer;
    private unwrapped;
    private unwrappedOutbound;
    private unwrappedInbound;
    private nextWrite;
    constructor(options?: streams.DuplexOptions);
    writeLP(input: Uint8Array): void;
    readLP(): Promise<Uint8Array>;
    unwrap(): streams.Duplex;
    _read(size: number): void;
    _write(chunk: any, encoding: BufferEncoding, callback: (error?: (Error | null)) => void): void;
}
export declare function createPbStream(): PbStreamImpl;