Module stream 

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

Structs

PeerSink 🔒

Per-peer egress buffer: a bounded MPSC crossfire channel.

Functions

process_stream_protocol

spawn_stream_pumps 🔒

Spawn the write and read pump tasks for an open peer stream.

Type Aliases

PeerStreamCache 🔒