/** * Some code borrowed from https://github.com/tarruda/node-msgpack5rpc */ import { EventEmitter } from 'node:events'; import { ASYNC_DISPOSE_SYMBOL } from './util'; export declare let exportsForTesting: any; declare class Transport extends EventEmitter { [ASYNC_DISPOSE_SYMBOL]: () => Promise; private pending; private nextRequestId; private reader; private writer; private readonly extensionCodec; private client; private initializeExtensionCodec; private encodeToBuffer; attach(writer: NodeJS.WritableStream, reader: NodeJS.ReadableStream, client: any): void; request(method: string, args: any[], cb: Function): void; notify(method: string, args: any[]): void; parseMessage(msg: any[]): void; /** * Close the transport. * * Ends the writer, the other end of the connection should close our reader which cleans up * remaining resources. */ close(): Promise; } export { Transport };