/**
 * 通常我们将先进入 opened 状态的称为 endpoint-0，其次是 endpoint-1
 */
import { Producer } from "@dweb-browser/helper/Producer.ts";
import { PromiseOut } from "@dweb-browser/helper/PromiseOut.ts";
import { StateSignal, type $ReadyonlyStateSignal } from "@dweb-browser/helper/StateSignal.ts";
import { CUSTOM_INSPECT } from "@dweb-browser/helper/logger.ts";
import type { $IpcMessage } from "../ipc-message/IpcMessage.js";
import type { Ipc } from "../ipc.js";
import type { $EndpointIpcMessage } from "./EndpointIpcMessage.js";
import { ENDPOINT_PROTOCOL, type $EndpointLifecycle } from "./EndpointLifecycle.js";
export declare abstract class IpcEndpoint {
    readonly debugId: string;
    readonly console: import("@dweb-browser/helper/logger.ts").Logger;
    constructor(debugId: string);
    abstract toString(): string;
    [CUSTOM_INSPECT](): string;
    private accPid;
    /**
     * 注册一个Pid
     * endpoint-0 的 ipc-fork 出来的 pid 是偶数
     * endpoint-1 的 ipc-fork 出来的 pid 是奇数
     */
    generatePid: () => number;
    /**
     * 发送消息
     */
    abstract postIpcMessage(msg: $EndpointIpcMessage): Promise<void>;
    /**
     * @internal
     * 获取消息管道
     */
    private ipcMessageProducers;
    private ipcMessageProducer;
    /**获取ipc消息的生产者 */
    getIpcMessageProducer(pid: number): {
        pid: number;
        ipcPo: PromiseOut<Ipc>;
        producer: Producer<$IpcMessage>;
    };
    /**通过ipc拿到ipc消息生产者对象 */
    getIpcMessageProducerByIpc(ipc: Ipc): {
        pid: number;
        ipcPo: PromiseOut<Ipc>;
        producer: Producer<$IpcMessage>;
    };
    /**
     * 本地的生命周期状态流
     */
    protected lifecycleLocaleFlow: StateSignal<$EndpointLifecycle>;
    /**
     * 生命周期 监听器
     */
    onLifecycle: (cb: import("@dweb-browser/helper/createSignal.js").$Callback<[$EndpointLifecycle]>) => import("@dweb-browser/helper/createSignal.js").$OffListener;
    /**
     * 当前生命周期
     */
    get lifecycle(): $EndpointLifecycle;
    /**
     * 远端的生命周期状态流
     */
    protected abstract lifecycleRemoteFlow: $ReadyonlyStateSignal<$EndpointLifecycle>;
    /**
     * 向远端发送 生命周期 信号
     */
    protected abstract sendLifecycleToRemote(state: $EndpointLifecycle): void;
    /**
     * 是否处于可以发送消息的状态
     */
    get isActivity(): boolean;
    /**
     * 获取支持的协议，在协商的时候会用到
     */
    protected abstract getLocaleSubProtocols(): Set<ENDPOINT_PROTOCOL>;
    /**
     * 启动生命周期的相关的工作
     */
    abstract doStart(): void;
    start(isAwait?: boolean): Promise<void>;
    readonly localSessionId: string;
    /**启动 */
    startOnce: (() => Promise<void>) & {
        readonly fn: () => Promise<void>;
        readonly hasRun: boolean;
        readonly result: Promise<void>;
        reset(): void;
    };
    /**等待启动 */
    awaitOpen(reason?: string): Promise<$EndpointLifecycle>;
    protected closedPo: PromiseOut<string | undefined>;
    private _isClose;
    get isClose(): boolean;
    close(cause?: string): Promise<void>;
    awaitClosed(): Promise<string | undefined>;
    doClose(cause?: string): Promise<void>;
    protected beforeClose?: (cause?: string) => void;
    protected afterClosed?: (cause?: string) => void;
}
//# sourceMappingURL=IpcEndpoint.d.ts.map