Struct MergeHub 

pub struct MergeHub<T: Send + 'static> { /* private fields */ }

Fan many dynamic producers into one consumer source.

Implementations

impl<T: Send + 'static> MergeHub<T>

pub fn new() -> Self

pub fn attach(&self, source: Source<T>)

Attach a producer source — pumped into the merged stream.

pub fn source(&self) -> Source<T>

Take the merged consumer source. Calling more than once yields an empty source (the receiver only exists once).

Trait Implementations

impl<T: Send + 'static> Default for MergeHub<T>

fn default() -> Self

Returns the “default value” for a type.