Skip to main content

NodeStreamTransport

@totemsdk/stream-transport

@totemsdk/stream-transport / NodeStreamTransport

Class: NodeStreamTransport

Wraps any Node.js Duplex-compatible stream (net.Socket, tls.TLSSocket, Hyperswarm connection, etc.) as IStreamTransport.

Extended by​

Implements​

Constructors​

Constructor​

new NodeStreamTransport(stream): NodeStreamTransport

Parameters​

stream​

unknown

Returns​

NodeStreamTransport

Accessors​

state​

Get Signature​

get state(): TransportState

Explicit connection state.

Returns​

TransportState

Explicit connection state.

Implementation of​

IStreamTransport.state

Methods​

close()​

close(): Promise<void>

Close the transport. After the returned promise resolves, no further data or close deliveries occur. Calling close() more than once is safe (the second call resolves immediately).

Returns​

Promise<void>

Implementation of​

IStreamTransport.close

onClose()​

onClose(handler): () => void

Subscribe to connection close. Returns an unsubscribe function.

Parameters​

handler​

CloseHandler

Returns​

() => void

Implementation of​

IStreamTransport.onClose

onData()​

onData(handler): () => void

Subscribe to data chunks. Returns an unsubscribe function.

Parameters​

handler​

DataHandler

Returns​

() => void

Implementation of​

IStreamTransport.onData

onError()​

onError(handler): () => void

Subscribe to transport errors. Returns an unsubscribe function.

Parameters​

handler​

ErrorHandler

Returns​

() => void

Implementation of​

IStreamTransport.onError

send()​

send(data): Promise<void>

Send bytes to the remote peer.

  • Returns a promise that resolves once the bytes are accepted by the underlying transport (or after the documented backpressure policy).
  • Rejects with ClosedTransportError if the transport is closed.
  • Rejects with the underlying error if delivery fails.

Parameters​

data​

Uint8Array

Returns​

Promise<void>

Implementation of​

IStreamTransport.send