AbstractWhether this stream is inbound or outbound
If no data is transmitted over the stream in this many ms, the stream will be aborted with an InactivityTimeoutError
ReadonlylogA logging implementation that can be used to log stream-specific messages
OptionalmaxThe maximum number of bytes to store when paused. If receipt of more bytes from the remote end of the stream causes the buffer size to exceed this value the stream will be reset and a 'close' event emitted.
This value can be changed at runtime.
OptionalmaxWhen the .send method returns false it means that the underlying resource
has signalled that it's write buffer is full. If the user continues to call
.send, outgoing bytes are stored in an internal buffer until the
underlying resource signals that it can accept more data.
If the size of that internal buffer exceed this value the stream will be reset and a 'close' event emitted.
This value can be changed at runtime.
Protected ReadonlyreadAny data stored here is emitted before any new incoming data.
This is used when the stream is paused or if data is pushed onto the stream
The address of the remote end of the connection
ProtectedsendingThe current status of the message stream
ReadonlytimelineTimestamps of when stream events occurred
If this property is true, the underlying transport has signalled that its
write buffer is full and that .send should not be called again.
A drain event will be emitted after which is its safe to call .send
again to resume sending.
Protected ReadonlywriteReturns the number of bytes that are queued to be read
Returns the number of bytes that are queued to be written
Close immediately for reading and writing and send a reset message (local error)
The addEventListener() method of the EventTarget interface sets up a function that will be called whenever the specified event is delivered to the target.
Optionaloptions: boolean | AddEventListenerOptionsOptionaloptions: boolean | AddEventListenerOptionsStop accepting new data to send and return a promise that resolves when any unsent data has been written into the underlying resource.
Optionaloptions: AbortOptionsThe dispatchEvent() method of the EventTarget sends an Event to the object, (synchronously) invoking the affected event listeners in the appropriate order. The normal event processing rules (including the capturing and optional bubbling phase) also apply to events dispatched manually with dispatchEvent().
The dispatchEvent() method of the EventTarget sends an Event to the object, (synchronously) invoking the affected event listeners in the appropriate order. The normal event processing rules (including the capturing and optional bubbling phase) also apply to events dispatched manually with dispatchEvent().
ProtecteddispatchWhen an extending class reads data from it's implementation-specific source, call this method to allow the stream consumer to read the data.
Returns a promise that resolves when the stream can accept new data or rejects if the stream is closed or reset before this occurs.
Optionaloptions: AbortOptionsCalled by extending classes when the remote closes its readable end
Called by extending classes when the remote closes its writable end
Receive a reset message - close immediately for reading and writing (remote error)
The underlying resource or transport this stream uses has closed - it is not possible to send any more messages though any data still in the read buffer may still be read
Optionalerr: ErrorStop emitting further 'message' events. Any received data will be stored in
an internal buffer. If the buffer size reaches maxReadBufferLength, the
stream will be reset and a StreamAbortEvent emitted.
If the underlying resource supports it, the remote peer will be instructed to pause transmission of further data.
ProtectedprocessQueue the passed data to be emitted as a 'message' event either during the next tick or sooner if data is received from the underlying resource.
The removeEventListener() method of the EventTarget interface removes an event listener previously registered with EventTarget.addEventListener() from the target. The event listener to be removed is identified using a combination of the event type, the event listener function itself, and various optional options that may affect the matching process; see Matching event listeners for removal.
Optionallistener: EventHandler<MessageStreamEvents[K]> | nullOptionaloptions: boolean | EventListenerOptionsResume emitting 'message' events.
If the underlying resource supports it, the remote peer will be informed that it is ok to start sending data again.
Optionaldetail: CustomEventInit<Detail>Write data to the stream. If the method returns false it means the internal buffer is now full and the caller should wait for the 'drain' event before sending more data.
This method may throw if:
AbstractsendWait for any unsent data to be written to the underlying resource, then close the resource and resolve the returned promise
Optionaloptions: AbortOptionsAbstractsendSend a data message to the remote end of the stream. Implementations of this method should return the number of bytes from the passed buffer that were sent successfully and if the underlying resource can accept more data.
The implementation should always attempt to send the maximum amount of data possible.
Returning a result that means the data was only partially sent but that the underlying resource can accept more data is invalid.
AbstractsendIf supported, instruct the remote end of the stream to temporarily stop sending data messages
AbstractsendAbstractsendIf supported, inform the remote end of the stream they may resume sending data messages
Similar to the .push method, except this ensures the passed data is
emitted before any other queued data.
A MultiaddrConnection is returned by a transport after dialing a peer. It is a low-level primitive and is the raw connection, typically without encryption or stream multiplexing.