1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use async_trait::async_trait;
use srtp::stream::Stream;

use crate::error::Result;
use crate::{Attributes, RTCPReader, RTPReader};

#[async_trait]
impl RTPReader for Stream {
    async fn read(
        &self,
        buf: &mut [u8],
        a: &Attributes,
    ) -> Result<(rtp::packet::Packet, Attributes)> {
        Ok((self.read_rtp(buf).await?, a.clone()))
    }
}

#[async_trait]
impl RTCPReader for Stream {
    async fn read(
        &self,
        buf: &mut [u8],
        a: &Attributes,
    ) -> Result<(Vec<Box<dyn rtcp::packet::Packet + Send + Sync>>, Attributes)> {
        Ok((self.read_rtcp(buf).await?, a.clone()))
    }
}