Trait timely::dataflow::operators::capture::event::EventPusher
[−]
[src]
pub trait EventPusher<T, D> { fn push(&mut self, event: Event<T, D>); }
Receives Event<T, D>
events.
Required Methods
Implementors
impl<T, D> EventPusher<T, D> for Rc<EventLink<T, D>>
impl<T: Abomonation, D: Abomonation, W: Write> EventPusher<T, D> for EventWriter<T, D, W>
impl<T, D> EventPusher<T, D> for Sender<Event<T, D>>