timely::dataflow::operators::core::capture::event

Trait EventPusher

Source
pub trait EventPusher<T, C> {
    // Required method
    fn push(&mut self, event: Event<T, C>);
}
Expand description

Receives Event<T, C> events.

Required Methods§

Source

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

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

Implementations on Foreign Types§

Source§

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

Source§

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

Source§

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

Source§

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

Implementors§

Source§

impl<T: Serialize, C: Serialize, W: Write> EventPusher<T, C> for EventWriter<T, C, W>

impl<P: Push<Event<T, D>>, T, D> EventPusher<T, D> for PusherCapture<P>

impl<T, C, M> EventPusher<T, C> for UnboundedTokioCapture<T, C, M>

impl<T, D, E: EventPusher<T, D>> EventPusher<T, D> for ActivatedEventPusher<E>