Struct timely::dataflow::channels::pact::Puller

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

Wraps a Message<T,D> puller to provide a Pull<(T, Content<D>)>.

Methods

impl<T, D, P: Pull<Message<T, D>>> Puller<T, D, P>

pub fn new(
    puller: P,
    index: usize,
    channel: usize,
    comm_channel: Option<usize>,
    logging: Logger
) -> Self

Allocates a new Puller.

Trait Implementations

impl<T, D, P: Pull<Message<T, D>>> Pull<(T, Content<D>)> for Puller<T, D, P>

fn pull(&mut self) -> &mut Option<(T, Content<D>)>

Pulls an element and provides the opportunity to take ownership.

fn recv(&mut self) -> Option<T>

Takes an Option<T> and leaves None behind.