70     pub fn new(stream: TcpStream, event_producer: StreamHubEventSender, gop_num: usize) -> Self {  in new()  method
78         let tcp_io: Box<dyn TNetIO + Send + Sync> = Box::new(TcpIO::new(stream));  in new()
79         let net_io = Arc::new(Mutex::new(tcp_io));  in new()
86             handshaker: HandshakeServer::new(Arc::clone(&net_io)),  in new()
87             unpacketizer: ChunkUnpacketizer::new(),  in new()
89             common: Common::new(  in new()
90                 Some(ChunkPacketizer::new(Arc::clone(&net_io))),  in new()
95             session_id: Uuid::new(RandomDigitCount::Four),  in new()
96             bytesio_data: BytesMut::new(),  in new()
190                             if let Some(mut msg) = MessageParser::new(chunk_info).parse()? {  in read_parse_chunks()
235             ProtocolControlMessagesWriter::new(AsyncBytesWriter::new(self.io.clone()));  in send_set_chunk_size()
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()
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()