Struct timely::communication::allocator::zero_copy::push_pull::Pusher

pub struct Pusher<T, P>
where
    P: BytesPush,
{ /* private fields */ }

An adapter into which one may push elements of type T.

This pusher has a fixed MessageHeader, and access to a SharedByteBuffer which it uses to acquire buffers for serialization.

Implementations

impl<T, P> Pusher<T, P>

where P: BytesPush,

pub fn new( header: MessageHeader, sender: Rc<RefCell<SendEndpoint<P>>>, ) -> Pusher<T, P>

Creates a new Pusher from a header and shared byte buffer.

Trait Implementations

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

where T: Bytesable, P: BytesPush,

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

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.