Struct timely_communication::allocator::zero_copy::push_pull::Pusher

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

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.

Methods

impl<T, P: BytesPush> Pusher<T, P>

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: Data, P: BytesPush> Push<Message<T>> for Pusher<T, P>

fn push(&mut self, element: &mut Option<Message<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.