import type { MessageTarget } from "./message-target.js";
export interface InvocationChannel {
    start(): Promise<void>;
    close(): Promise<void>;
    invoke<T = unknown>(request?: unknown, ...transfers: Transferable[]): Promise<T>;
}
export interface NewInvocationChannelOptions {
    port: MessageTarget;
    handler?: (request: unknown, ...ports: MessagePort[]) => unknown;
    onError?: (error: unknown) => void;
    newCallId?: () => number;
}
export declare function newInvokationChannel({ port, handler, onError, newCallId, }: NewInvocationChannelOptions): InvocationChannel;
export declare function sendStream<T>(communicationPort: MessageTarget, input: AsyncIterable<T>, params?: Record<string, unknown>): AsyncGenerator<T, void, unknown>;
export type StreamHandler<T> = (input: AsyncIterable<T>, params: Record<string, unknown>) => AsyncIterable<T> | Promise<AsyncIterable<T>>;
export declare function handleStreams<T>(communicationPort: MessageTarget, handler: StreamHandler<T>): () => void;
//# sourceMappingURL=data-channels.d.ts.map