Module stream 

Stream processing utilities Infrastructure supporting converting a collection of [PeerId] split libp2p_stream managed individual peer-to-peer libp2p::swarm::Streams.

Constants

DEFAULT_FRAME_WRITER_BACKPRESSURE_BYTES 🔒

Default pending-write-buffer byte threshold on the framed writer before a flush is forced. This value is in bytes, not in messages — that is how tokio_util::codec::FramedWrite::set_backpressure_boundary is defined.

GLOBAL_STREAM_OPEN_TIMEOUT 🔒

Global timeout for the BidirectionalStreamControl::open operation.

MAX_CONCURRENT_PACKETS 🔒

Functions

build_peer_stream_io 🔒

process_stream_protocol