Struct SrsppStream 

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

A scoped receiver for one source address.

Created by serve for each new connection. recv() only returns messages from this source.

Implementations

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

pub fn source(&self) -> Address

Returns the source address of this connection.

pub async fn recv(&mut self, buf: &mut [u8]) -> Result<usize, TransportError<E>>

Receives the next message from this source.

pub async fn recv_with<F, Ret>( &mut self, f: F, ) -> Result<Ret, TransportError<E>>

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

Receives and processes a message in-place with a closure.