71     io: Arc<Mutex<Box<dyn TNetIO + Send + Sync>>>,  field
128             io: Arc::clone(&net_io),  in new()
184             let data = self.io.lock().await.read().await?;  in run()
220                 let data = self.io.lock().await.read().await?;  in handshake()
342         let mut netconnection = NetConnection::new(Arc::clone(&self.io));  in send_connect()
378         let mut netconnection = NetConnection::new(Arc::clone(&self.io));  in send_create_stream()
389         let mut netstream = NetStreamWriter::new(Arc::clone(&self.io));  in send_delete_stream()
403         let mut netstream = NetStreamWriter::new(Arc::clone(&self.io));  in send_publish()
419         let mut netstream = NetStreamWriter::new(Arc::clone(&self.io));  in send_play()
424         let mut netconnection = NetConnection::new(Arc::clone(&self.io));  in send_play()
436             ProtocolControlMessagesWriter::new(AsyncBytesWriter::new(self.io.clone()));  in send_set_chunk_size()
446             ProtocolControlMessagesWriter::new(AsyncBytesWriter::new(self.io.clone()));  in send_window_acknowledgement_size()
458         let mut eventmessages = EventMessagesWriter::new(AsyncBytesWriter::new(self.io.clone()));  in send_set_buffer_length()
466             ProtocolControlMessagesWriter::new(AsyncBytesWriter::new(self.io.clone()));  in on_result_connect()
469         let mut netstream = NetStreamWriter::new(Arc::clone(&self.io));  in on_result_connect()