Lines Matching refs:io
63 io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, field
114 let io = Arc::new(Mutex::new(net_io)); in new() localVariable
117 io: io.clone(), in new()
119 writer: AsyncBytesWriter::new(io), in new()
131 let data = self.io.lock().await.read().await?; in run()
139 let data = self.io.lock().await.read().await?; in run()
168 track.on_rtcp(&mut cur_reader, self.io.clone()).await; in on_rtp_over_rtsp_message()
348 track.create_packer(self.io.clone()).await; in handle_setup()
428 move |io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, packet: RtpPacket| { in handle_play()
431 let mut bytes_writer = AsyncBytesWriter::new(io); in handle_play()
444 move |io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>, packet: RtpPacket| { in handle_play()
446 let mut bytes_writer = AsyncBytesWriter::new(io); in handle_play()