Create source/sink iterables for a duplex stream where each message should be acknowledged
Creates a duplex stream
Turn a writable and readable stream into a streams2 duplex stream with support for async initialization and streams1/streams2 input
Wraps a duplex stream and hides the readable or the writable interface
Promised out of order transform.
Typescript types for AsyncIterable sink/source/duplex streams
Node-RED AMQP input and output nodes with ack and prefetch
Create a duplex stream from a writable and a readable
Make a full duplex stream with 2 Duplex endpoints, using the native version of `Duplex`
Create handshakes for binary protocols with iterable streams
Add a goodbye handshake to a duplex async iterable
Type Safe RPC library.
base class for a duplex stream
Return promise for duplex stream
Duplex wrapper for RDFJS Sink
Simple async iterables for websocket client connections
Channel for easy streaming of work between complex logics.
A convenience-wrapper around protocol-buffers and lp-messages functions
Simple, robust, BitTorrent peer wire protocol implementation
Create a duplex stream from a readable and a writable stream.
Combine an array of streams into a single duplex stream using pump and duplexify
A JavaScript Ethereum provider that connects to the wallet over a stream
TypeScript definitions for mute-stream
Modern version of `duplexer2`