Struct tokio_stream::wrappers::BroadcastStream [−][src]
pub struct BroadcastStream<T> { /* fields omitted */ }
This is supported on crate feature
sync
only.Expand description
A wrapper around tokio::sync::broadcast::Receiver
that implements Stream
.
Implementations
Trait Implementations
type Item = Result<T, BroadcastStreamRecvError>
type Item = Result<T, BroadcastStreamRecvError>
Values yielded by the stream.
Attempt to pull out the next value of this stream, registering the
current task for wakeup if the value is not yet available, and returning
None
if the stream is exhausted. Read more