Trait timely::dataflow::operators::capture::event::EventPusher

pub trait EventPusher<T, D> {
    fn push(&mut self, event: Event<T, D>);
}

Receives Event<T, D> events.

Required methods

fn push(&mut self, event: Event<T, D>)

Provides a new Event<T, D> to the pusher.

Loading content...

Implementations on Foreign Types

impl<T, D> EventPusher<T, D> for Sender<Event<T, D>>

fn push(&mut self, event: Event<T, D>)

impl<T, D> EventPusher<T, D> for Rc<EventLink<T, D>>

fn push(&mut self, event: Event<T, D>)

Loading content...

Implementors

impl<T: Abomonation, D: Abomonation, W: Write> EventPusher<T, D> for EventWriter<T, D, W>

fn push(&mut self, event: Event<T, D>)

Loading content...