Struct timely::communication::allocator::zero_copy::push_pull::PullerInner

pub struct PullerInner<T> { /* private fields */ }

An adapter from which one can pull elements of type T.

This type is very simple, and just consumes owned Vec<u8> allocations. It is not the most efficient thing possible, which would probably instead be something like the bytes crate (../bytes/) which provides an exclusive view of a shared allocation.

Implementations

impl<T> PullerInner<T>

where T: Data,

pub fn new( inner: Box<dyn Pull<Message<T>>>, receiver: Rc<RefCell<VecDeque<Bytes>>>, _canary: Canary ) -> PullerInner<T>

Creates a new PullerInner instance from a shared queue.

Trait Implementations

impl<T> Pull<Message<T>> for PullerInner<T>

where T: Data,

fn pull(&mut self) -> &mut Option<Message<T>>

Pulls an element and provides the opportunity to take ownership.

fn recv(&mut self) -> Option<T>

Takes an Option<T> and leaves None behind.