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: ?Sized + Push<T>> Push<T> for Box<P>

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

Implementors

impl<T> Push<T> for timely_communication::allocator::thread::Pusher<T>

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

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

impl<T: Bytesable, P: BytesPush> Push<T> for timely_communication::allocator::zero_copy::push_pull::Pusher<T, P>