/// <reference types="web" />
import { PromiseOut } from "@dweb-browser/helper/PromiseOut.ts";
import type { $MicroModuleManifest } from "../types.js";
import type { IpcHeaders } from "./helper/IpcHeaders.js";
import { IpcClientRequest, IpcServerRequest } from "./ipc-message/IpcRequest.js";
import { IpcResponse } from "./ipc-message/IpcResponse.js";
import { Producer } from "@dweb-browser/helper/Producer.ts";
import { CUSTOM_INSPECT } from "@dweb-browser/helper/logger.ts";
import type { IpcPool } from "./IpcPool.js";
import type { IpcEndpoint } from "./endpoint/IpcEndpoint.js";
import { type $IpcLifecycle } from "./ipc-message/IpcLifecycle.js";
import type { $IpcMessage } from "./ipc-message/IpcMessage.js";
import { IPC_MESSAGE_TYPE } from "./ipc-message/internal/IpcMessage.js";
export declare class Ipc {
    #private;
    readonly pid: number;
    readonly endpoint: IpcEndpoint;
    readonly locale: $MicroModuleManifest;
    readonly remote: $MicroModuleManifest;
    readonly pool: IpcPool;
    readonly debugId: string;
    readonly console: import("@dweb-browser/helper/logger.ts").Logger;
    constructor(pid: number, endpoint: IpcEndpoint, locale: $MicroModuleManifest, remote: $MicroModuleManifest, pool: IpcPool, debugId?: string);
    toString(): string;
    [CUSTOM_INSPECT](): string;
    onMessage(name: string): {
        readonly name: string;
        readonly producer: Producer<$IpcMessage>;
        toString(): string;
        readonly input: {
            "__#6@#cb"?: ((event: {
                readonly data: $IpcMessage;
                readonly producer: Producer<$IpcMessage>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): $IpcMessage;
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R>(mapNotNull: (data: $IpcMessage) => R | undefined): R | undefined;
                consumeFilter<R_1 extends $IpcMessage = $IpcMessage>(filter: (data: $IpcMessage) => boolean | undefined): R_1 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }) => unknown) | undefined;
            close(): void;
            collect(cb: (event: {
                readonly data: $IpcMessage;
                readonly producer: Producer<$IpcMessage>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): $IpcMessage;
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R_2>(mapNotNull: (data: $IpcMessage) => R_2 | undefined): R_2 | undefined;
                consumeFilter<R_1_1 extends $IpcMessage = $IpcMessage>(filter: (data: $IpcMessage) => boolean | undefined): R_1_1 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }) => unknown): void;
            emit(event: {
                readonly data: $IpcMessage;
                readonly producer: Producer<$IpcMessage>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): $IpcMessage;
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R_3>(mapNotNull: (data: $IpcMessage) => R_3 | undefined): R_3 | undefined;
                consumeFilter<R_1_2 extends $IpcMessage = $IpcMessage>(filter: (data: $IpcMessage) => boolean | undefined): R_1_2 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }): Promise<void>;
        };
        "__#7@#started": boolean;
        readonly started: boolean;
        startingBuffers: Set<{
            readonly data: $IpcMessage;
            readonly producer: Producer<$IpcMessage>;
            toString(): string;
            "__#5@#job": PromiseOut<void>;
            readonly job: Promise<void>;
            "__#5@#consumeTimes": number;
            readonly consumed: boolean;
            consume(): $IpcMessage;
            "__#5@#stoped": boolean;
            readonly stoped: boolean;
            stopImmediatePropagation(): void;
            complete(): void;
            consumeMapNotNull<R_4>(mapNotNull: (data: $IpcMessage) => R_4 | undefined): R_4 | undefined;
            consumeFilter<R_1_3 extends $IpcMessage = $IpcMessage>(filter: (data: $IpcMessage) => boolean | undefined): R_1_3 | undefined;
            "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
            emitBy(consumer: any): Promise<void> | undefined;
            "inspect.custom"(): string;
        }> | null;
        "__#7@#errorCatcher": PromiseOut<string | undefined>;
        "__#7@#start"(): void;
        collect(collector: (event: {
            readonly data: $IpcMessage;
            readonly producer: Producer<$IpcMessage>;
            toString(): string;
            "__#5@#job": PromiseOut<void>;
            readonly job: Promise<void>;
            "__#5@#consumeTimes": number;
            readonly consumed: boolean;
            consume(): $IpcMessage;
            "__#5@#stoped": boolean;
            readonly stoped: boolean;
            stopImmediatePropagation(): void;
            complete(): void;
            consumeMapNotNull<R_5>(mapNotNull: (data: $IpcMessage) => R_5 | undefined): R_5 | undefined;
            consumeFilter<R_1_4 extends $IpcMessage = $IpcMessage>(filter: (data: $IpcMessage) => boolean | undefined): R_1_4 | undefined;
            "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
            emitBy(consumer: any): Promise<void> | undefined;
            "inspect.custom"(): string;
        }) => void): void;
        mapNotNull<R_2>(transform: (value: $IpcMessage) => R_2 | undefined): (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[R_2]>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
        "__#7@#destroySignal": import("@dweb-browser/helper/createSignal.js").Signal<import("@dweb-browser/helper/createSignal.js").$Callback<[], unknown>>;
        onDestroy: (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[], unknown>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
        close(cause?: string | undefined): void;
        "inspect.custom"(): string;
    };
    readonly lifecycleLocaleFlow: import("@dweb-browser/helper/StateSignal.ts").$ReadyonlyStateSignal<$IpcLifecycle>;
    get lifecycle(): $IpcLifecycle;
    onLifecycle: (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[$IpcLifecycle]>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
    readonly lifecycleRemoteFlow: (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[$IpcLifecycle]>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
    get isActivity(): boolean;
    /**等待启动 */
    awaitOpen(reason?: string): Promise<$IpcLifecycle>;
    /**
     * 启动，会至少等到endpoint握手完成
     */
    start(isAwait?: boolean, reason?: string): Promise<void>;
    startOnce: (() => void) & {
        readonly fn: () => void;
        readonly hasRun: boolean;
        readonly result: void;
        reset(): void;
    };
    private forkedIpcMap;
    waitForkedIpc(pid: number): Promise<Ipc>;
    /**
     * 在现有的线路中分叉出一个ipc通道
     * 如果自定义了 locale/remote，那么说明自己是帮别人代理
     */
    fork(locale?: $MicroModuleManifest, remote?: $MicroModuleManifest, autoStart?: boolean, startReason?: string): Promise<Ipc>;
    onFork(name: string): {
        readonly name: string;
        readonly producer: Producer<Ipc>;
        toString(): string;
        readonly input: {
            "__#6@#cb"?: ((event: {
                readonly data: Ipc;
                readonly producer: Producer<Ipc>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): Ipc;
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R>(mapNotNull: (data: Ipc) => R | undefined): R | undefined;
                consumeFilter<R_1 extends Ipc = Ipc>(filter: (data: Ipc) => boolean | undefined): R_1 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }) => unknown) | undefined;
            close(): void;
            collect(cb: (event: {
                readonly data: Ipc;
                readonly producer: Producer<Ipc>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): Ipc;
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R_2>(mapNotNull: (data: Ipc) => R_2 | undefined): R_2 | undefined;
                consumeFilter<R_1_1 extends Ipc = Ipc>(filter: (data: Ipc) => boolean | undefined): R_1_1 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }) => unknown): void;
            emit(event: {
                readonly data: Ipc;
                readonly producer: Producer<Ipc>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): Ipc;
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R_3>(mapNotNull: (data: Ipc) => R_3 | undefined): R_3 | undefined;
                consumeFilter<R_1_2 extends Ipc = Ipc>(filter: (data: Ipc) => boolean | undefined): R_1_2 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }): Promise<void>;
        };
        "__#7@#started": boolean;
        readonly started: boolean;
        startingBuffers: Set<{
            readonly data: Ipc;
            readonly producer: Producer<Ipc>;
            toString(): string;
            "__#5@#job": PromiseOut<void>;
            readonly job: Promise<void>;
            "__#5@#consumeTimes": number;
            readonly consumed: boolean;
            consume(): Ipc;
            "__#5@#stoped": boolean;
            readonly stoped: boolean;
            stopImmediatePropagation(): void;
            complete(): void;
            consumeMapNotNull<R_4>(mapNotNull: (data: Ipc) => R_4 | undefined): R_4 | undefined;
            consumeFilter<R_1_3 extends Ipc = Ipc>(filter: (data: Ipc) => boolean | undefined): R_1_3 | undefined;
            "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
            emitBy(consumer: any): Promise<void> | undefined;
            "inspect.custom"(): string;
        }> | null;
        "__#7@#errorCatcher": PromiseOut<string | undefined>;
        "__#7@#start"(): void;
        collect(collector: (event: {
            readonly data: Ipc;
            readonly producer: Producer<Ipc>;
            toString(): string;
            "__#5@#job": PromiseOut<void>;
            readonly job: Promise<void>;
            "__#5@#consumeTimes": number;
            readonly consumed: boolean;
            consume(): Ipc;
            "__#5@#stoped": boolean;
            readonly stoped: boolean;
            stopImmediatePropagation(): void;
            complete(): void;
            consumeMapNotNull<R_5>(mapNotNull: (data: Ipc) => R_5 | undefined): R_5 | undefined;
            consumeFilter<R_1_4 extends Ipc = Ipc>(filter: (data: Ipc) => boolean | undefined): R_1_4 | undefined;
            "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
            emitBy(consumer: any): Promise<void> | undefined;
            "inspect.custom"(): string;
        }) => void): void;
        mapNotNull<R_2>(transform: (value: Ipc) => R_2 | undefined): (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[R_2]>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
        "__#7@#destroySignal": import("@dweb-browser/helper/createSignal.js").Signal<import("@dweb-browser/helper/createSignal.js").$Callback<[], unknown>>;
        onDestroy: (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[], unknown>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
        close(cause?: string | undefined): void;
        "inspect.custom"(): string;
    };
    onRequest(name: string): {
        readonly name: string;
        readonly producer: Producer<IpcServerRequest>;
        toString(): string;
        readonly input: {
            "__#6@#cb"?: ((event: {
                readonly data: IpcServerRequest;
                readonly producer: Producer<IpcServerRequest>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): IpcServerRequest;
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R>(mapNotNull: (data: IpcServerRequest) => R | undefined): R | undefined;
                consumeFilter<R_1 extends IpcServerRequest = IpcServerRequest>(filter: (data: IpcServerRequest) => boolean | undefined): R_1 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }) => unknown) | undefined;
            close(): void;
            collect(cb: (event: {
                readonly data: IpcServerRequest;
                readonly producer: Producer<IpcServerRequest>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): IpcServerRequest;
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R_2>(mapNotNull: (data: IpcServerRequest) => R_2 | undefined): R_2 | undefined;
                consumeFilter<R_1_1 extends IpcServerRequest = IpcServerRequest>(filter: (data: IpcServerRequest) => boolean | undefined): R_1_1 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }) => unknown): void;
            emit(event: {
                readonly data: IpcServerRequest;
                readonly producer: Producer<IpcServerRequest>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): IpcServerRequest;
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R_3>(mapNotNull: (data: IpcServerRequest) => R_3 | undefined): R_3 | undefined;
                consumeFilter<R_1_2 extends IpcServerRequest = IpcServerRequest>(filter: (data: IpcServerRequest) => boolean | undefined): R_1_2 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }): Promise<void>;
        };
        "__#7@#started": boolean;
        readonly started: boolean;
        startingBuffers: Set<{
            readonly data: IpcServerRequest;
            readonly producer: Producer<IpcServerRequest>;
            toString(): string;
            "__#5@#job": PromiseOut<void>;
            readonly job: Promise<void>;
            "__#5@#consumeTimes": number;
            readonly consumed: boolean;
            consume(): IpcServerRequest;
            "__#5@#stoped": boolean;
            readonly stoped: boolean;
            stopImmediatePropagation(): void;
            complete(): void;
            consumeMapNotNull<R_4>(mapNotNull: (data: IpcServerRequest) => R_4 | undefined): R_4 | undefined;
            consumeFilter<R_1_3 extends IpcServerRequest = IpcServerRequest>(filter: (data: IpcServerRequest) => boolean | undefined): R_1_3 | undefined;
            "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
            emitBy(consumer: any): Promise<void> | undefined;
            "inspect.custom"(): string;
        }> | null;
        "__#7@#errorCatcher": PromiseOut<string | undefined>;
        "__#7@#start"(): void;
        collect(collector: (event: {
            readonly data: IpcServerRequest;
            readonly producer: Producer<IpcServerRequest>;
            toString(): string;
            "__#5@#job": PromiseOut<void>;
            readonly job: Promise<void>;
            "__#5@#consumeTimes": number;
            readonly consumed: boolean;
            consume(): IpcServerRequest;
            "__#5@#stoped": boolean;
            readonly stoped: boolean;
            stopImmediatePropagation(): void;
            complete(): void;
            consumeMapNotNull<R_5>(mapNotNull: (data: IpcServerRequest) => R_5 | undefined): R_5 | undefined;
            consumeFilter<R_1_4 extends IpcServerRequest = IpcServerRequest>(filter: (data: IpcServerRequest) => boolean | undefined): R_1_4 | undefined;
            "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
            emitBy(consumer: any): Promise<void> | undefined;
            "inspect.custom"(): string;
        }) => void): void;
        mapNotNull<R_2>(transform: (value: IpcServerRequest) => R_2 | undefined): (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[R_2]>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
        "__#7@#destroySignal": import("@dweb-browser/helper/createSignal.js").Signal<import("@dweb-browser/helper/createSignal.js").$Callback<[], unknown>>;
        onDestroy: (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[], unknown>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
        close(cause?: string | undefined): void;
        "inspect.custom"(): string;
    };
    onResponse(name: string): {
        readonly name: string;
        readonly producer: Producer<IpcResponse>;
        toString(): string;
        readonly input: {
            "__#6@#cb"?: ((event: {
                readonly data: IpcResponse;
                readonly producer: Producer<IpcResponse>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): IpcResponse;
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R>(mapNotNull: (data: IpcResponse) => R | undefined): R | undefined;
                consumeFilter<R_1 extends IpcResponse = IpcResponse>(filter: (data: IpcResponse) => boolean | undefined): R_1 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }) => unknown) | undefined;
            close(): void;
            collect(cb: (event: {
                readonly data: IpcResponse;
                readonly producer: Producer<IpcResponse>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): IpcResponse;
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R_2>(mapNotNull: (data: IpcResponse) => R_2 | undefined): R_2 | undefined;
                consumeFilter<R_1_1 extends IpcResponse = IpcResponse>(filter: (data: IpcResponse) => boolean | undefined): R_1_1 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }) => unknown): void;
            emit(event: {
                readonly data: IpcResponse;
                readonly producer: Producer<IpcResponse>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): IpcResponse;
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R_3>(mapNotNull: (data: IpcResponse) => R_3 | undefined): R_3 | undefined;
                consumeFilter<R_1_2 extends IpcResponse = IpcResponse>(filter: (data: IpcResponse) => boolean | undefined): R_1_2 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }): Promise<void>;
        };
        "__#7@#started": boolean;
        readonly started: boolean;
        startingBuffers: Set<{
            readonly data: IpcResponse;
            readonly producer: Producer<IpcResponse>;
            toString(): string;
            "__#5@#job": PromiseOut<void>;
            readonly job: Promise<void>;
            "__#5@#consumeTimes": number;
            readonly consumed: boolean;
            consume(): IpcResponse;
            "__#5@#stoped": boolean;
            readonly stoped: boolean;
            stopImmediatePropagation(): void;
            complete(): void;
            consumeMapNotNull<R_4>(mapNotNull: (data: IpcResponse) => R_4 | undefined): R_4 | undefined;
            consumeFilter<R_1_3 extends IpcResponse = IpcResponse>(filter: (data: IpcResponse) => boolean | undefined): R_1_3 | undefined;
            "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
            emitBy(consumer: any): Promise<void> | undefined;
            "inspect.custom"(): string;
        }> | null;
        "__#7@#errorCatcher": PromiseOut<string | undefined>;
        "__#7@#start"(): void;
        collect(collector: (event: {
            readonly data: IpcResponse;
            readonly producer: Producer<IpcResponse>;
            toString(): string;
            "__#5@#job": PromiseOut<void>;
            readonly job: Promise<void>;
            "__#5@#consumeTimes": number;
            readonly consumed: boolean;
            consume(): IpcResponse;
            "__#5@#stoped": boolean;
            readonly stoped: boolean;
            stopImmediatePropagation(): void;
            complete(): void;
            consumeMapNotNull<R_5>(mapNotNull: (data: IpcResponse) => R_5 | undefined): R_5 | undefined;
            consumeFilter<R_1_4 extends IpcResponse = IpcResponse>(filter: (data: IpcResponse) => boolean | undefined): R_1_4 | undefined;
            "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
            emitBy(consumer: any): Promise<void> | undefined;
            "inspect.custom"(): string;
        }) => void): void;
        mapNotNull<R_2>(transform: (value: IpcResponse) => R_2 | undefined): (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[R_2]>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
        "__#7@#destroySignal": import("@dweb-browser/helper/createSignal.js").Signal<import("@dweb-browser/helper/createSignal.js").$Callback<[], unknown>>;
        onDestroy: (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[], unknown>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
        close(cause?: string | undefined): void;
        "inspect.custom"(): string;
    };
    onStream(name: string): {
        readonly name: string;
        readonly producer: Producer<{
            readonly stream_id: string;
            readonly data: string | Uint8Array;
            readonly encoding: import("./index.js").IPC_DATA_ENCODING;
            readonly order: number;
            readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
        } | {
            readonly stream_id: string;
            readonly bandwidth: number;
            readonly order: number;
            readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
        } | {
            readonly stream_id: string;
            readonly fuse: number;
            readonly order: number;
            readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
        } | {
            readonly stream_id: string;
            readonly order: number;
            readonly type: IPC_MESSAGE_TYPE.STREAM_END;
        } | {
            readonly stream_id: string;
            readonly order: number;
            readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
        }>;
        toString(): string;
        readonly input: {
            "__#6@#cb"?: ((event: {
                readonly data: {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                };
                readonly producer: Producer<{
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                }>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                };
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R>(mapNotNull: (data: {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                }) => R | undefined): R | undefined;
                consumeFilter<R_1 extends {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                } = {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                }>(filter: (data: {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                }) => boolean | undefined): R_1 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }) => unknown) | undefined;
            close(): void;
            collect(cb: (event: {
                readonly data: {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                };
                readonly producer: Producer<{
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                }>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                };
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R_2>(mapNotNull: (data: {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                }) => R_2 | undefined): R_2 | undefined;
                consumeFilter<R_1_1 extends {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                } = {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                }>(filter: (data: {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                }) => boolean | undefined): R_1_1 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }) => unknown): void;
            emit(event: {
                readonly data: {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                };
                readonly producer: Producer<{
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                }>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                };
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R_3>(mapNotNull: (data: {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                }) => R_3 | undefined): R_3 | undefined;
                consumeFilter<R_1_2 extends {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                } = {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                }>(filter: (data: {
                    readonly stream_id: string;
                    readonly data: string | Uint8Array;
                    readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
                } | {
                    readonly stream_id: string;
                    readonly bandwidth: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
                } | {
                    readonly stream_id: string;
                    readonly fuse: number;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_END;
                } | {
                    readonly stream_id: string;
                    readonly order: number;
                    readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
                }) => boolean | undefined): R_1_2 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }): Promise<void>;
        };
        "__#7@#started": boolean;
        readonly started: boolean;
        startingBuffers: Set<{
            readonly data: {
                readonly stream_id: string;
                readonly data: string | Uint8Array;
                readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
            } | {
                readonly stream_id: string;
                readonly bandwidth: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
            } | {
                readonly stream_id: string;
                readonly fuse: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_END;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
            };
            readonly producer: Producer<{
                readonly stream_id: string;
                readonly data: string | Uint8Array;
                readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
            } | {
                readonly stream_id: string;
                readonly bandwidth: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
            } | {
                readonly stream_id: string;
                readonly fuse: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_END;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
            }>;
            toString(): string;
            "__#5@#job": PromiseOut<void>;
            readonly job: Promise<void>;
            "__#5@#consumeTimes": number;
            readonly consumed: boolean;
            consume(): {
                readonly stream_id: string;
                readonly data: string | Uint8Array;
                readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
            } | {
                readonly stream_id: string;
                readonly bandwidth: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
            } | {
                readonly stream_id: string;
                readonly fuse: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_END;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
            };
            "__#5@#stoped": boolean;
            readonly stoped: boolean;
            stopImmediatePropagation(): void;
            complete(): void;
            consumeMapNotNull<R_4>(mapNotNull: (data: {
                readonly stream_id: string;
                readonly data: string | Uint8Array;
                readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
            } | {
                readonly stream_id: string;
                readonly bandwidth: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
            } | {
                readonly stream_id: string;
                readonly fuse: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_END;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
            }) => R_4 | undefined): R_4 | undefined;
            consumeFilter<R_1_3 extends {
                readonly stream_id: string;
                readonly data: string | Uint8Array;
                readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
            } | {
                readonly stream_id: string;
                readonly bandwidth: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
            } | {
                readonly stream_id: string;
                readonly fuse: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_END;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
            } = {
                readonly stream_id: string;
                readonly data: string | Uint8Array;
                readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
            } | {
                readonly stream_id: string;
                readonly bandwidth: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
            } | {
                readonly stream_id: string;
                readonly fuse: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_END;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
            }>(filter: (data: {
                readonly stream_id: string;
                readonly data: string | Uint8Array;
                readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
            } | {
                readonly stream_id: string;
                readonly bandwidth: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
            } | {
                readonly stream_id: string;
                readonly fuse: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_END;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
            }) => boolean | undefined): R_1_3 | undefined;
            "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
            emitBy(consumer: any): Promise<void> | undefined;
            "inspect.custom"(): string;
        }> | null;
        "__#7@#errorCatcher": PromiseOut<string | undefined>;
        "__#7@#start"(): void;
        collect(collector: (event: {
            readonly data: {
                readonly stream_id: string;
                readonly data: string | Uint8Array;
                readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
            } | {
                readonly stream_id: string;
                readonly bandwidth: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
            } | {
                readonly stream_id: string;
                readonly fuse: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_END;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
            };
            readonly producer: Producer<{
                readonly stream_id: string;
                readonly data: string | Uint8Array;
                readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
            } | {
                readonly stream_id: string;
                readonly bandwidth: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
            } | {
                readonly stream_id: string;
                readonly fuse: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_END;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
            }>;
            toString(): string;
            "__#5@#job": PromiseOut<void>;
            readonly job: Promise<void>;
            "__#5@#consumeTimes": number;
            readonly consumed: boolean;
            consume(): {
                readonly stream_id: string;
                readonly data: string | Uint8Array;
                readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
            } | {
                readonly stream_id: string;
                readonly bandwidth: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
            } | {
                readonly stream_id: string;
                readonly fuse: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_END;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
            };
            "__#5@#stoped": boolean;
            readonly stoped: boolean;
            stopImmediatePropagation(): void;
            complete(): void;
            consumeMapNotNull<R_5>(mapNotNull: (data: {
                readonly stream_id: string;
                readonly data: string | Uint8Array;
                readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
            } | {
                readonly stream_id: string;
                readonly bandwidth: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
            } | {
                readonly stream_id: string;
                readonly fuse: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_END;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
            }) => R_5 | undefined): R_5 | undefined;
            consumeFilter<R_1_4 extends {
                readonly stream_id: string;
                readonly data: string | Uint8Array;
                readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
            } | {
                readonly stream_id: string;
                readonly bandwidth: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
            } | {
                readonly stream_id: string;
                readonly fuse: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_END;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
            } = {
                readonly stream_id: string;
                readonly data: string | Uint8Array;
                readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
            } | {
                readonly stream_id: string;
                readonly bandwidth: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
            } | {
                readonly stream_id: string;
                readonly fuse: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_END;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
            }>(filter: (data: {
                readonly stream_id: string;
                readonly data: string | Uint8Array;
                readonly encoding: import("./index.js").IPC_DATA_ENCODING;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
            } | {
                readonly stream_id: string;
                readonly bandwidth: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
            } | {
                readonly stream_id: string;
                readonly fuse: number;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_END;
            } | {
                readonly stream_id: string;
                readonly order: number;
                readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
            }) => boolean | undefined): R_1_4 | undefined;
            "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
            emitBy(consumer: any): Promise<void> | undefined;
            "inspect.custom"(): string;
        }) => void): void;
        mapNotNull<R_2>(transform: (value: {
            readonly stream_id: string;
            readonly data: string | Uint8Array;
            readonly encoding: import("./index.js").IPC_DATA_ENCODING;
            readonly order: number;
            readonly type: IPC_MESSAGE_TYPE.STREAM_DATA;
        } | {
            readonly stream_id: string;
            readonly bandwidth: number;
            readonly order: number;
            readonly type: IPC_MESSAGE_TYPE.STREAM_PULLING;
        } | {
            readonly stream_id: string;
            readonly fuse: number;
            readonly order: number;
            readonly type: IPC_MESSAGE_TYPE.STREAM_PAUSED;
        } | {
            readonly stream_id: string;
            readonly order: number;
            readonly type: IPC_MESSAGE_TYPE.STREAM_END;
        } | {
            readonly stream_id: string;
            readonly order: number;
            readonly type: IPC_MESSAGE_TYPE.STREAM_ABORT;
        }) => R_2 | undefined): (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[R_2]>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
        "__#7@#destroySignal": import("@dweb-browser/helper/createSignal.js").Signal<import("@dweb-browser/helper/createSignal.js").$Callback<[], unknown>>;
        onDestroy: (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[], unknown>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
        close(cause?: string | undefined): void;
        "inspect.custom"(): string;
    };
    onEvent(name: string): {
        readonly name: string;
        readonly producer: Producer<import("./index.js").$IpcEvent>;
        toString(): string;
        readonly input: {
            "__#6@#cb"?: ((event: {
                readonly data: import("./index.js").$IpcEvent;
                readonly producer: Producer<import("./index.js").$IpcEvent>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): import("./index.js").$IpcEvent;
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R>(mapNotNull: (data: import("./index.js").$IpcEvent) => R | undefined): R | undefined;
                consumeFilter<R_1 extends import("./index.js").$IpcEvent = import("./index.js").$IpcEvent>(filter: (data: import("./index.js").$IpcEvent) => boolean | undefined): R_1 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }) => unknown) | undefined;
            close(): void;
            collect(cb: (event: {
                readonly data: import("./index.js").$IpcEvent;
                readonly producer: Producer<import("./index.js").$IpcEvent>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): import("./index.js").$IpcEvent;
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R_2>(mapNotNull: (data: import("./index.js").$IpcEvent) => R_2 | undefined): R_2 | undefined;
                consumeFilter<R_1_1 extends import("./index.js").$IpcEvent = import("./index.js").$IpcEvent>(filter: (data: import("./index.js").$IpcEvent) => boolean | undefined): R_1_1 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }) => unknown): void;
            emit(event: {
                readonly data: import("./index.js").$IpcEvent;
                readonly producer: Producer<import("./index.js").$IpcEvent>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): import("./index.js").$IpcEvent;
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R_3>(mapNotNull: (data: import("./index.js").$IpcEvent) => R_3 | undefined): R_3 | undefined;
                consumeFilter<R_1_2 extends import("./index.js").$IpcEvent = import("./index.js").$IpcEvent>(filter: (data: import("./index.js").$IpcEvent) => boolean | undefined): R_1_2 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }): Promise<void>;
        };
        "__#7@#started": boolean;
        readonly started: boolean;
        startingBuffers: Set<{
            readonly data: import("./index.js").$IpcEvent;
            readonly producer: Producer<import("./index.js").$IpcEvent>;
            toString(): string;
            "__#5@#job": PromiseOut<void>;
            readonly job: Promise<void>;
            "__#5@#consumeTimes": number;
            readonly consumed: boolean;
            consume(): import("./index.js").$IpcEvent;
            "__#5@#stoped": boolean;
            readonly stoped: boolean;
            stopImmediatePropagation(): void;
            complete(): void;
            consumeMapNotNull<R_4>(mapNotNull: (data: import("./index.js").$IpcEvent) => R_4 | undefined): R_4 | undefined;
            consumeFilter<R_1_3 extends import("./index.js").$IpcEvent = import("./index.js").$IpcEvent>(filter: (data: import("./index.js").$IpcEvent) => boolean | undefined): R_1_3 | undefined;
            "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
            emitBy(consumer: any): Promise<void> | undefined;
            "inspect.custom"(): string;
        }> | null;
        "__#7@#errorCatcher": PromiseOut<string | undefined>;
        "__#7@#start"(): void;
        collect(collector: (event: {
            readonly data: import("./index.js").$IpcEvent;
            readonly producer: Producer<import("./index.js").$IpcEvent>;
            toString(): string;
            "__#5@#job": PromiseOut<void>;
            readonly job: Promise<void>;
            "__#5@#consumeTimes": number;
            readonly consumed: boolean;
            consume(): import("./index.js").$IpcEvent;
            "__#5@#stoped": boolean;
            readonly stoped: boolean;
            stopImmediatePropagation(): void;
            complete(): void;
            consumeMapNotNull<R_5>(mapNotNull: (data: import("./index.js").$IpcEvent) => R_5 | undefined): R_5 | undefined;
            consumeFilter<R_1_4 extends import("./index.js").$IpcEvent = import("./index.js").$IpcEvent>(filter: (data: import("./index.js").$IpcEvent) => boolean | undefined): R_1_4 | undefined;
            "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
            emitBy(consumer: any): Promise<void> | undefined;
            "inspect.custom"(): string;
        }) => void): void;
        mapNotNull<R_2>(transform: (value: import("./index.js").$IpcEvent) => R_2 | undefined): (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[R_2]>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
        "__#7@#destroySignal": import("@dweb-browser/helper/createSignal.js").Signal<import("@dweb-browser/helper/createSignal.js").$Callback<[], unknown>>;
        onDestroy: (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[], unknown>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
        close(cause?: string | undefined): void;
        "inspect.custom"(): string;
    };
    onError(name: string): {
        readonly name: string;
        readonly producer: Producer<{
            readonly errorCode: number;
            readonly message: string | undefined;
            readonly type: IPC_MESSAGE_TYPE.ERROR;
        }>;
        toString(): string;
        readonly input: {
            "__#6@#cb"?: ((event: {
                readonly data: {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                };
                readonly producer: Producer<{
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                }>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                };
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R>(mapNotNull: (data: {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                }) => R | undefined): R | undefined;
                consumeFilter<R_1 extends {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                } = {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                }>(filter: (data: {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                }) => boolean | undefined): R_1 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }) => unknown) | undefined;
            close(): void;
            collect(cb: (event: {
                readonly data: {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                };
                readonly producer: Producer<{
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                }>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                };
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R_2>(mapNotNull: (data: {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                }) => R_2 | undefined): R_2 | undefined;
                consumeFilter<R_1_1 extends {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                } = {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                }>(filter: (data: {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                }) => boolean | undefined): R_1_1 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }) => unknown): void;
            emit(event: {
                readonly data: {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                };
                readonly producer: Producer<{
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                }>;
                toString(): string;
                "__#5@#job": PromiseOut<void>;
                readonly job: Promise<void>;
                "__#5@#consumeTimes": number;
                readonly consumed: boolean;
                consume(): {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                };
                "__#5@#stoped": boolean;
                readonly stoped: boolean;
                stopImmediatePropagation(): void;
                complete(): void;
                consumeMapNotNull<R_3>(mapNotNull: (data: {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                }) => R_3 | undefined): R_3 | undefined;
                consumeFilter<R_1_2 extends {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                } = {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                }>(filter: (data: {
                    readonly errorCode: number;
                    readonly message: string | undefined;
                    readonly type: IPC_MESSAGE_TYPE.ERROR;
                }) => boolean | undefined): R_1_2 | undefined;
                "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
                emitBy(consumer: any): Promise<void> | undefined;
                "inspect.custom"(): string;
            }): Promise<void>;
        };
        "__#7@#started": boolean;
        readonly started: boolean;
        startingBuffers: Set<{
            readonly data: {
                readonly errorCode: number;
                readonly message: string | undefined;
                readonly type: IPC_MESSAGE_TYPE.ERROR;
            };
            readonly producer: Producer<{
                readonly errorCode: number;
                readonly message: string | undefined;
                readonly type: IPC_MESSAGE_TYPE.ERROR;
            }>;
            toString(): string;
            "__#5@#job": PromiseOut<void>;
            readonly job: Promise<void>;
            "__#5@#consumeTimes": number;
            readonly consumed: boolean;
            consume(): {
                readonly errorCode: number;
                readonly message: string | undefined;
                readonly type: IPC_MESSAGE_TYPE.ERROR;
            };
            "__#5@#stoped": boolean;
            readonly stoped: boolean;
            stopImmediatePropagation(): void;
            complete(): void;
            consumeMapNotNull<R_4>(mapNotNull: (data: {
                readonly errorCode: number;
                readonly message: string | undefined;
                readonly type: IPC_MESSAGE_TYPE.ERROR;
            }) => R_4 | undefined): R_4 | undefined;
            consumeFilter<R_1_3 extends {
                readonly errorCode: number;
                readonly message: string | undefined;
                readonly type: IPC_MESSAGE_TYPE.ERROR;
            } = {
                readonly errorCode: number;
                readonly message: string | undefined;
                readonly type: IPC_MESSAGE_TYPE.ERROR;
            }>(filter: (data: {
                readonly errorCode: number;
                readonly message: string | undefined;
                readonly type: IPC_MESSAGE_TYPE.ERROR;
            }) => boolean | undefined): R_1_3 | undefined;
            "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
            emitBy(consumer: any): Promise<void> | undefined;
            "inspect.custom"(): string;
        }> | null;
        "__#7@#errorCatcher": PromiseOut<string | undefined>;
        "__#7@#start"(): void;
        collect(collector: (event: {
            readonly data: {
                readonly errorCode: number;
                readonly message: string | undefined;
                readonly type: IPC_MESSAGE_TYPE.ERROR;
            };
            readonly producer: Producer<{
                readonly errorCode: number;
                readonly message: string | undefined;
                readonly type: IPC_MESSAGE_TYPE.ERROR;
            }>;
            toString(): string;
            "__#5@#job": PromiseOut<void>;
            readonly job: Promise<void>;
            "__#5@#consumeTimes": number;
            readonly consumed: boolean;
            consume(): {
                readonly errorCode: number;
                readonly message: string | undefined;
                readonly type: IPC_MESSAGE_TYPE.ERROR;
            };
            "__#5@#stoped": boolean;
            readonly stoped: boolean;
            stopImmediatePropagation(): void;
            complete(): void;
            consumeMapNotNull<R_5>(mapNotNull: (data: {
                readonly errorCode: number;
                readonly message: string | undefined;
                readonly type: IPC_MESSAGE_TYPE.ERROR;
            }) => R_5 | undefined): R_5 | undefined;
            consumeFilter<R_1_4 extends {
                readonly errorCode: number;
                readonly message: string | undefined;
                readonly type: IPC_MESSAGE_TYPE.ERROR;
            } = {
                readonly errorCode: number;
                readonly message: string | undefined;
                readonly type: IPC_MESSAGE_TYPE.ERROR;
            }>(filter: (data: {
                readonly errorCode: number;
                readonly message: string | undefined;
                readonly type: IPC_MESSAGE_TYPE.ERROR;
            }) => boolean | undefined): R_1_4 | undefined;
            "__#5@#emitLock": import("@dweb-browser/helper/Mutex.js").Mutex;
            emitBy(consumer: any): Promise<void> | undefined;
            "inspect.custom"(): string;
        }) => void): void;
        mapNotNull<R_2>(transform: (value: {
            readonly errorCode: number;
            readonly message: string | undefined;
            readonly type: IPC_MESSAGE_TYPE.ERROR;
        }) => R_2 | undefined): (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[R_2]>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
        "__#7@#destroySignal": import("@dweb-browser/helper/createSignal.js").Signal<import("@dweb-browser/helper/createSignal.js").$Callback<[], unknown>>;
        onDestroy: (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[], unknown>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
        close(cause?: string | undefined): void;
        "inspect.custom"(): string;
    };
    /** 发起请求并等待响应 */
    request(url: IpcClientRequest): Promise<IpcResponse>;
    request(url: string, init?: $IpcRequestInit): Promise<IpcResponse>;
    postMessage(message: $IpcMessage): Promise<void>;
    private get _closePo();
    awaitClosed(): Promise<string | undefined>;
    get onClosed(): (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[string | undefined]>) => void;
    get isClosed(): boolean;
    close(cause?: string): Promise<void>;
    prepareChannel(headers: IpcHeaders, channelIpc?: Ipc | Promise<Ipc>): Promise<Ipc>;
}
export type $IpcRequestInit = {
    method?: string;
    body?: null | string | ArrayBuffer | ArrayBufferView | Blob | ReadableStream<Uint8Array>;
    headers?: IpcHeaders | HeadersInit;
};
//# sourceMappingURL=ipc.d.ts.map