53     io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,  field
85             io: Arc::clone(&net_io),  in new()
128             self.bytesio_data = self.io.lock().await.read().await?;  in handshake()
153                 .io  in read_parse_chunks()
235             ProtocolControlMessagesWriter::new(AsyncBytesWriter::new(self.io.clone()));  in send_set_chunk_size()
430             ProtocolControlMessagesWriter::new(AsyncBytesWriter::new(self.io.clone()));  in on_connect()
460         let mut netconnection = NetConnection::new(Arc::clone(&self.io));  in on_connect()
478         let mut netconnection = NetConnection::new(Arc::clone(&self.io));  in on_create_stream()
504         let mut netstream = NetStreamWriter::new(Arc::clone(&self.io));  in on_delete_stream()
587         let mut event_messages = EventMessagesWriter::new(AsyncBytesWriter::new(self.io.clone()));  in on_play()
601         let mut netstream = NetStreamWriter::new(Arc::clone(&self.io));  in on_play()
716         let mut event_messages = EventMessagesWriter::new(AsyncBytesWriter::new(self.io.clone()));  in on_publish()
719         let mut netstream = NetStreamWriter::new(Arc::clone(&self.io));  in on_publish()