Struct timely::dataflow::channels::pact::Pusher

pub struct Pusher<T, D, P: Push<Message<T, D>>> { /* fields omitted */ }

Wraps a Message<T,D> pusher to provide a Push<(T, Content<D>)>.

Methods

impl<T, D, P: Push<Message<T, D>>> Pusher<T, D, P>

pub fn new(
    pusher: P,
    source: usize,
    target: usize,
    channel: usize,
    comm_channel: Option<usize>,
    logging: Logger
) -> Self

Allocates a new pusher.

Trait Implementations

impl<T, D, P: Push<Message<T, D>>> Push<(T, Content<D>)> for Pusher<T, D, P>

fn push(&mut self, pair: &mut Option<(T, Content<D>)>)

Pushes element and provides the opportunity to take ownership.

fn send(&mut self, element: T)

Pushes element and drops any resulting resources.

fn done(&mut self)

Pushes None, conventionally signalling a flush.