Trait timely::communication::Push

pub trait Push<T> {
    // Required method
    fn push(&mut self, element: &mut Option<T>);

    // Provided methods
    fn send(&mut self, element: T) { ... }
    fn done(&mut self) { ... }
}

Pushing elements of type T.

This trait moves data around using references rather than ownership, which provides the opportunity for zero-copy operation. In the call to push(element) the implementor can swap some other value to replace element, effectively returning the value to the caller.

Conventionally, a sequence of calls to push() should conclude with a call of push(&mut None) or done() to signal to implementors that another call to push() may not be coming.

Required Methods

fn push(&mut self, element: &mut Option<T>)

Pushes element with the opportunity to take ownership.

Provided Methods

fn send(&mut self, element: T)

Pushes element and drops any resulting resources.

fn done(&mut self)

Pushes None, conventionally signalling a flush.

Implementations on Foreign Types

impl<T, P> Push<T> for Box<P>

where P: Push<T> + ?Sized,

fn push(&mut self, element: &mut Option<T>)

Implementors

impl<T> Push<T> for timely::communication::allocator::thread::Pusher<T>

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

impl<T, P> Push<Message<T>> for timely::communication::allocator::zero_copy::push_pull::Pusher<T, P>

where T: Data, P: BytesPush,

impl<T, P> Push<T> for ArcPusher<T, P>

where P: Push<T>,

impl<T, P> Push<T> for timely::communication::allocator::counters::Pusher<T, P>

where P: Push<T>,

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

where P: Push<Bundle<T, C>>,

impl<T: Data, C: Container> Push<Message<Message<T, C>>> for Tee<T, C>

impl<T: Eq + Data, C, P: Push<Bundle<T, C>>, H> Push<Message<Message<T, C>>> for Exchange<T, C, P, H>

where C: PushPartitioned + Container, for<'a> H: FnMut(&C::Item<'a>) -> u64,