Struct DeliveryToken 

pub struct DeliveryToken<'a, 'rx, E, R: ReceiverBackend, const MAX_STREAMS: usize> { /* private fields */ }

Zero-copy delivery token returned by SrsppRxHandle::wait_for_message.

Holds &mut SrsppRxHandle, preventing another receive while the token is alive. The cell is not borrowed — the driver freely delivers new segments in the background.

Call consume with a synchronous closure to read the message and release the token in one step.

Implementations

impl<'a, 'rx, E: Clone, R: ReceiverBackend, const MAX_STREAMS: usize> DeliveryToken<'a, 'rx, E, R, MAX_STREAMS>

pub fn len(&self) -> usize

Byte length of the pending message.

pub fn source(&self) -> Address

Source address of the sender that produced this message.

pub fn consume<F, Ret>(self, f: F) -> Ret

where F: FnOnce(&[u8]) -> Ret,

Pass the message data to f, consume the token, and return whatever f returns.

The cell is borrowed only for the duration of f.