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.

StallGuardSink 🔒

A [Sink] adapter that fails the per-peer write pump once the inner sink stops making progress.

Enums

EgressWriteError 🔒

Error produced by the per-peer write pump (StallGuardSink).

Functions

process_stream_protocol

spawn_stream_pumps 🔒

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

Type Aliases

PeerStreamCache 🔒