fedimint_core::util

Module broadcaststream

Source
Expand description

Copied from tokio_stream 0.1.12 to use our optional Send bounds

Structs§

BroadcastStream
A wrapper around tokio::sync::broadcast::Receiver that implements Stream.

Enums§

BroadcastStreamRecvError
An error returned from the inner stream of a BroadcastStream.

Functions§

make_future 🔒