Skip to main content

Module stream

Module stream 

Source
Expand description

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