Struct interceptor::mock::mock_stream::MockStream

pub struct MockStream { /* private fields */ }

MockStream is a helper struct for testing interceptors.

Implementations

impl MockStream

pub async fn new( info: &StreamInfo, interceptor: Arc<dyn Interceptor + Send + Sync> ) -> Arc<Self>

new creates a new MockStream

pub async fn write_rtcp( &self, pkt: &[Box<dyn Packet + Send + Sync>] ) -> Result<usize, Error>

write_rtcp writes a batch of rtcp packet to the stream, using the interceptor

pub async fn write_rtp(&self, pkt: &Packet) -> Result<usize, Error>

write_rtp writes an rtp packet to the stream, using the interceptor

pub async fn receive_rtcp(&self, pkts: Vec<Box<dyn Packet + Send + Sync>>)

receive_rtcp schedules a new rtcp batch, so it can be read be the stream

pub async fn receive_rtp(&self, pkt: Packet)

receive_rtp schedules a rtp packet, so it can be read be the stream

pub async fn written_rtcp(&self) -> Option<Vec<Box<dyn Packet + Send + Sync>>>

written_rtcp returns a channel containing the rtcp batches written, modified by the interceptor

pub async fn last_written_rtcp( &self ) -> Option<Vec<Box<dyn Packet + Send + Sync>>>

Returns the last rtcp packet bacth that was written, modified by the interceptor.

NB: This method discards all other previously recoreded packet batches.

pub async fn written_rtp(&self) -> Option<Packet>

written_rtp returns a channel containing rtp packets written, modified by the interceptor

pub async fn read_rtcp( &self ) -> Option<Result<Vec<Box<dyn Packet + Send + Sync>>, Error>>

read_rtcp returns a channel containing the rtcp batched read, modified by the interceptor

pub async fn read_rtp(&self) -> Option<Result<Packet, Error>>

read_rtp returns a channel containing the rtp packets read, modified by the interceptor

pub async fn close(&self) -> Result<(), Error>

close closes the stream and the underlying interceptor

Trait Implementations

impl RTCPReader for MockStream

fn read<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, buf: &'life1 mut [u8], a: &'life2 Attributes ) -> Pin<Box<dyn Future<Output = Result<(Vec<Box<dyn Packet + Send + Sync>>, Attributes), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

read a batch of rtcp packets

impl RTCPWriter for MockStream

fn write<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, pkts: &'life1 [Box<dyn Packet + Send + Sync>], _attributes: &'life2 Attributes ) -> Pin<Box<dyn Future<Output = Result<usize, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

write a batch of rtcp packets

impl RTPReader for MockStream

fn read<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, buf: &'life1 mut [u8], a: &'life2 Attributes ) -> Pin<Box<dyn Future<Output = Result<(Packet, Attributes), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

read a rtp packet

impl RTPWriter for MockStream

fn write<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, pkt: &'life1 Packet, _a: &'life2 Attributes ) -> Pin<Box<dyn Future<Output = Result<usize, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

write a rtp packet