Struct timely::dataflow::channels::pact::LogPuller

pub struct LogPuller<T, C, P: Pull<Bundle<T, C>>> { /* private fields */ }

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

Implementations

impl<T, C, P: Pull<Bundle<T, C>>> LogPuller<T, C, P>

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

Allocates a new Puller.

Trait Implementations

impl<T: Debug, C: Debug, P: Debug + Pull<Bundle<T, C>>> Debug for LogPuller<T, C, P>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T, C: Container, P: Pull<Bundle<T, C>>> Pull<Bincode<Message<T, C>>> for LogPuller<T, C, P>

fn pull(&mut self) -> &mut Option<Bundle<T, C>>

Pulls an element and provides the opportunity to take ownership.

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

Takes an Option<T> and leaves None behind.