Interface Transport<TMessage>

Optionalcapabilities

Optionalclose

• close(): void

  Close the transport and release runtime resources.

  Returns void

OptionalonClose

• onClose(listener: (reason?: Error) => void): () => void

  Optionally register a listener invoked at most once when the transport permanently stops delivering messages because the connection dropped (remote close or network error). It is NOT invoked for a local close(). reason is an Error for abnormal termination and undefined for a clean remote close. Registering after the transport has already closed invokes the listener asynchronously with the recorded reason. Returns an unsubscribe function.

  When present, RPCChannel uses it to reject pending requests immediately instead of waiting for their timeouts. Transports that omit it behave as before: pending requests resolve, time out, or wait for destroy().

  Parameters

  • listener: (reason?: Error) => void

  Returns () => void

send

• send(message: TMessage, transfers?: Transferable[]): void | Promise<void>

  Send one message, optionally with transferables when supported.

  Parameters

  • message: TMessage
  • Optionaltransfers: Transferable[]

  Returns void | Promise<void>

subscribe

• subscribe(listener: (message: TMessage) => void): () => void

  Subscribe to incoming messages and return an unsubscribe callback.

  Parameters

  • listener: (message: TMessage) => void

  Returns () => void