Struct BufferReceiver 

pub struct BufferReceiver { /* private fields */ }

A receiver handle from a memory buffer.

Implementations

impl BufferReceiver

pub async fn recv(&mut self) -> Option<EventBatch>

Receives the next batch from the buffer.

pub fn try_recv(&mut self) -> Result<EventBatch, TryRecvError>

Tries to receive the next batch from the buffer without blocking.

Trait Implementations

impl Debug for BufferReceiver

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.