Struct timely::communication::allocator::zero_copy::bytes_exchange::MergeQueue

pub struct MergeQueue { /* private fields */ }

An unbounded queue of bytes intended for point-to-point communication between threads. Cloning returns another handle to the same queue.

TODO: explain “extend”

Implementations

impl MergeQueue

pub fn new(buzzer: Buzzer) -> MergeQueue

Allocates a new queue with an associated signal.

pub fn is_complete(&self) -> bool

Indicates that all input handles to the queue have dropped.

Trait Implementations

impl BytesPull for MergeQueue

fn drain_into(&mut self, vec: &mut Vec<Bytes>)

Drains many bytes from the instance.

impl BytesPush for MergeQueue

fn extend<I>(&mut self, iterator: I)

where I: IntoIterator<Item = Bytes>,

Pushes many bytes at the instance.

impl Clone for MergeQueue

fn clone(&self) -> MergeQueue

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Drop for MergeQueue

fn drop(&mut self)

Executes the destructor for this type.