Searched refs:rtp_writer (Results 1 – 2 of 2) sorted by relevance
17 rtp_writer: Mutex<Option<Arc<dyn RTPWriter + Send + Sync>>>, field50 rtp_writer: Mutex::new(None), in new()73 let rtp_writer = interceptor in new() localVariable80 let mut rw = stream.rtp_writer.lock().await; in new()81 *rw = Some(rtp_writer); in new()167 let rtp_writer = self.rtp_writer.lock().await; in write_rtp() localVariable168 if let Some(writer) = &*rtp_writer { in write_rtp()
749 rtp_writer: Arc<dyn RTPWriter + Send + Sync>, field754 fn new(rtp_writer: Arc<dyn RTPWriter + Send + Sync>, tx: mpsc::Sender<Message>) -> Self { in new()755 Self { rtp_writer, tx } in new()769 let n = self.rtp_writer.write(pkt, attributes).await?; in write()