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

pub struct Pusher<T, D> {
    // some fields omitted
}

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

Methods

impl<T, D> Pusher<T, D>

fn new(pusher: Box<Push<Message<T, D>>>, source: usize, target: usize, channel: usize) -> Pusher<T, D>

Allocates a new pusher.

Trait Implementations

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

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.