94     pub fn new(  in new()  method
110         let tcp_io: Box<dyn TNetIO + Send + Sync> = Box::new(TcpIO::new(stream));  in new()
111         let net_io = Arc::new(Mutex::new(tcp_io));  in new()
113         let subscriber_id = Uuid::new(RandomDigitCount::Four);  in new()
116             Some(ChunkPacketizer::new(Arc::clone(&net_io)))  in new()
121         let common = Common::new(packetizer, event_producer, SessionType::Client, remote_addr);  in new()
130             handshaker: SimpleHandshakeClient::new(Arc::clone(&net_io)),  in new()
131             unpacketizer: ChunkUnpacketizer::new(),  in new()
193                                     MessageParser::new(chunk_info.clone()).parse()?  in run()
289         let empty_cmd_name = &String::new();  in on_amf0_command_message()
300         let empty_cmd_obj: IndexMap<String, Amf0ValueType> = IndexMap::new();  in on_amf0_command_message()
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()