Struct rubble::link::queue::SimpleConsumer

pub struct SimpleConsumer<'a> {
    inner: Consumer<'a, [u8; 29], 2>,
}

Consumer (reader) half returned by SimpleQueue::split.

Fields

inner: Consumer<'a, [u8; 29], 2>

Trait Implementations

impl<'a> Consumer for SimpleConsumer<'a>

fn has_data(&self) -> bool

Returns whether there is a packet to dequeue.

fn consume_raw_with<R>(
    &mut self,
    f: impl FnOnce(Header, &[u8]) -> Consume<R>
) -> Result<R, Error>

Passes the next raw packet in the queue to a closure.

fn consume_pdu_with<R>(
    &mut self,
    f: impl FnOnce(Header, Pdu<'_, &[u8]>) -> Consume<R>
) -> Result<R, Error>

Passes the next packet in the queue to a closure.