Struct timely::dataflow::channels::pushers::tee::Tee
[−]
[src]
pub struct Tee<T: 'static, D: 'static> { /* fields omitted */ }
Wraps a shared list of Box<Push>
to forward pushes to. Owned by Stream
.
Methods
impl<T, D> Tee<T, D>
[src]
Trait Implementations
impl<T: Clone + 'static, D: Abomonation + Clone + 'static> Push<(T, Content<D>)> for Tee<T, D>
[src]
fn push(&mut self, message: &mut Option<(T, Content<D>)>)
[src]
Pushes element
and provides the opportunity to take ownership. Read more
fn send(&mut self, element: T)
[src]
Pushes element
and drops any resulting resources.
fn done(&mut self)
[src]
Pushes None
, conventionally signalling a flush.