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: Bytesable> PullerInner<T>

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

Creates a new PullerInner instance from a shared queue.

Trait Implementations

impl<T: Bytesable> Pull<T> for PullerInner<T>

fn pull(&mut self) -> &mut Option<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.