Struct timely::dataflow::channels::pact::LogPusher

pub struct LogPusher<T, C, P: Push<Message<T, C>>> { /* private fields */ }

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

Implementations

impl<T, C, P: Push<Message<T, C>>> LogPusher<T, C, P>

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

Allocates a new pusher.

Trait Implementations

impl<T: Debug, C: Debug, P: Debug + Push<Message<T, C>>> Debug for LogPusher<T, C, P>

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

Formats the value using the given formatter.

impl<T, C: Container, P: Push<Message<T, C>>> Push<Message<T, C>> for LogPusher<T, C, P>

fn push(&mut self, pair: &mut Option<Message<T, C>>)

Pushes element with 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.