import { ChildProcess } from "child_process"; import type { AllEventKeys } from "../events/event-bus.js"; import { EventEmitter, type AllEvents } from "../events/event-emitter.js"; import type { EventListener, EventOptions } from "../events/shared.js"; import { IsomorphicBuffer } from "../helpers.js"; import { SocketAdapterAkalaEventMap, SocketAdapter } from "./shared.js"; import { type Subscription } from "../teardown-manager.js"; import { Deferred } from "../promiseHelpers.js"; export declare class ProcessStdioAdapter extends EventEmitter implements SocketAdapter { private process; messageEvent: (args_0: string | IsomorphicBuffer) => void; openEvent: (args_0: Event) => void; closeEvent: (args_0: CloseEvent) => void; errorEvent: (args_0: Event) => void; get open(): boolean; pipe(socket: SocketAdapter): void; close(): Promise; send(data: string | IsomorphicBuffer): Promise; private readonly messageListeners; off>(event: TEvent, handler?: EventListener[TEvent]>): boolean; on>(event: TEvent, handler: EventListener[TEvent]>, options?: EventOptions[TEvent]>): Subscription; once>(event: TEvent, handler: EventListener[TEvent]>): Subscription; constructor(process: NodeJS.Process, abort: AbortSignal); } export declare class ChildProcessStdioAdapter extends EventEmitter implements SocketAdapter { private process; messageEvent: (args_0: string) => void; openEvent: (args_0: Event) => void; closeEvent: (args_0: CloseEvent) => void; get open(): boolean; pipe(socket: SocketAdapter): void; close(): Deferred; send(data: string): Promise; off>(event: TEvent, handler: EventListener[TEvent]>): boolean; on>(event: TEvent, handler: EventListener[TEvent]>, options?: EventOptions[TEvent]>): Subscription; once>(event: TEvent, handler: EventListener[TEvent]>, options?: Omit[TEvent]>, 'once'>): Subscription; constructor(process: ChildProcess, abort: AbortSignal); }