Trait timely_communication::Push

source ·
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) { ... }
}
Expand description

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§

source

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

Pushes element with the opportunity to take ownership.

Provided Methods§

source

fn send(&mut self, element: T)

Pushes element and drops any resulting resources.

source

fn done(&mut self)

Pushes None, conventionally signalling a flush.

Implementations on Foreign Types§

source§

impl<T, P: ?Sized + Push<T>> Push<T> for Box<P>

source§

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

Implementors§

source§

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

source§

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

source§

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

source§

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