Skip to content

NodeSocketTransport

Defined in: protocol/src/node-socket-transport.ts:16

Transport for one framed data-plane connection.

new NodeSocketTransport(_socket): NodeSocketTransport

Defined in: protocol/src/node-socket-transport.ts:19

Socket

NodeSocketTransport

close(): void

Defined in: protocol/src/node-socket-transport.ts:50

Tear the connection down and reject any pending backpressure waits.

void

FrameTransport.close


pause(): void

Defined in: protocol/src/node-socket-transport.ts:42

Pause inbound data (receive-side backpressure).

void

FrameTransport.pause


resume(): void

Defined in: protocol/src/node-socket-transport.ts:46

Resume inbound data.

void

FrameTransport.resume


writeFrame(header, payload): Promise<void>

Defined in: protocol/src/node-socket-transport.ts:31

Write header+payload as one frame.

Write BEFORE await to prevent deadlock: the buffers are handed to the socket synchronously (the header buffer is owned by the caller and never reused, so no defensive copy is needed), and only then do we wait out any backpressure.

Buffer

Buffer

Promise<void>

FrameTransport.writeFrame