Struct MergeQueue 

pub struct MergeQueue { /* private fields */ }

An unbounded queue of bytes intended for point-to-point communication between threads. Writer/reader handle pairs are obtained via MergeQueue::new_pair.

Implementations

impl MergeQueue

pub fn new(buzzer: Buzzer) -> MergeQueue

Allocates a new queue with an associated signal.

pub fn new_pair( buzzer: Buzzer, writer_policy: Option<Box<dyn SpillPolicy>>, reader_policy: Option<Box<dyn SpillPolicy>>, ) -> (MergeQueue, MergeQueue)

Allocates a matched pair of handles on the same underlying queue, each carrying its own policy. The first (writer) runs its policy after each extend; the second (reader) runs its policy before each drain_into.

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 Drop for MergeQueue

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.