Searched refs:rtp_reader (Results 1 – 2 of 2) sorted by relevance
114 let rtp_reader = interceptor in new() localVariable124 let n = match rtp_reader.read(&mut buf, &a).await { in new()
706 rtp_reader: Arc<dyn RTPReader + Send + Sync>, field711 fn new(rtp_reader: Arc<dyn RTPReader + Send + Sync>, tx: mpsc::Sender<Message>) -> Self { in new()712 Self { rtp_reader, tx } in new()725 let (bytes_read, attributes) = self.rtp_reader.read(buf, attributes).await?; in read()