import { JDDevice } from "./device";
import { Packet } from "./packet";
import { JDBus } from "./bus";
import { JDClient } from "./client";
import { JDService } from "./service";
export declare class OutPipe {
    private device;
    private port;
    readonly hosted?: boolean;
    private _count;
    constructor(device: JDDevice, port: number, hosted?: boolean);
    static from(bus: JDBus, pkt: Packet, hosted?: boolean): OutPipe;
    get count(): number;
    get isOpen(): boolean;
    send(buf: Uint8Array): Promise<void>;
    sendMeta(buf: Uint8Array): Promise<void>;
    respondForEach<T>(items: ArrayLike<T>, converter: (item: T) => Uint8Array): Promise<void>;
    private sendData;
    private free;
    close(): Promise<void>;
    sendBytes(data: Uint8Array): Promise<void>;
    static sendBytes(service: JDService, cmd: number, data: Uint8Array, onProgress?: (p: number) => void): Promise<void>;
}
export declare class InPipe extends JDClient {
    protected readonly bus: JDBus;
    private _port;
    private _count;
    constructor(bus: JDBus);
    get port(): number;
    get count(): number;
    get isOpen(): boolean;
    private allocPort;
    openCommand(cmd: number): Packet;
    private _handlePacket;
    close(): void;
}
export declare class InPipeReader extends InPipe {
    private done;
    private meta;
    private output;
    constructor(bus: JDBus);
    readData(timeout?: number): Promise<Uint8Array[]>;
    readBytes(timeout?: number): Promise<Uint8Array>;
    readAll(timeout?: number): Promise<{
        meta: Packet[];
        output: Packet[];
    }>;
}
//# sourceMappingURL=pipes.d.ts.map