Trait timely::dataflow::operators::capture::event::EventPusherCore

pub trait EventPusherCore<T, D> {
    // Required method
    fn push(&mut self, event: EventCore<T, D>);
}

Receives EventCore<T, D> events.

Required Methods

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

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

Implementations on Foreign Types

impl<T, D> EventPusherCore<T, D> for Rc<EventLinkCore<T, D>>

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

impl<T, D> EventPusherCore<T, D> for Sender<EventCore<T, D>>

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

Implementors

impl<T: Abomonation, D: Abomonation, W: Write> EventPusherCore<T, D> for EventWriterCore<T, D, W>