Struct interceptor::mock::mock_stream::MockStream

pub struct MockStream { /* fields omitted */ }

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 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>

cose 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<(usize, Attributes), Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    Self: '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
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    Self: '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<(usize, Attributes), Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    Self: '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
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    Self: 'async_trait, 

write a rtp packet