86     fn new(reader: &mut BytesReader) -> Result<Option<Self>, SessionError> {  in new()  method
105     pub fn new(stream: TcpStream, event_producer: StreamHubEventSender) -> Self {  in new()  method
113         let net_io: Box<dyn TNetIO + Send + Sync> = Box::new(TcpIO::new(stream));  in new()
114         let io = Arc::new(Mutex::new(net_io));  in new()
118             reader: BytesReader::new(BytesMut::default()),  in new()
119             writer: AsyncBytesWriter::new(io),  in new()
120             tracks: HashMap::new(),  in new()
124             stream_handler: Arc::new(RtspStreamHandler::new()),  in new()
135             if let Ok(data) = InterleavedBinaryData::new(&mut self.reader) {  in run()
158         let mut cur_reader = BytesReader::new(self.reader.read_bytes(length)?);  in on_rtp_over_rtsp_message()
301             rtp_channel_guard.on_frame_handler(Box::new(  in handle_announce()
311             rtp_channel_guard.on_packet_for_rtcp_handler(Box::new(move |packet: RtpPacket| {  in handle_announce()
337                     self.session_id = Some(Uuid::new(RandomDigitCount::Zero));  in handle_setup()
360                             if let Some(rtp_io) = UdpIO::new(address.clone(), rtp_port, 0).await {  in handle_setup()
363                                 let box_udp_io: Box<dyn TNetIO + Send + Sync> = Box::new(rtp_io);  in handle_setup()
366                                     track.create_packer(Arc::new(Mutex::new(box_udp_io))).await;  in handle_setup()
373                                 UdpIO::new(address.clone(), rtcp_port, rtp_server_port.unwrap() + 1)  in handle_setup()
378                                     Arc::new(Mutex::new(Box::new(rtcp_io)));  in handle_setup()
427                     track.rtp_channel.lock().await.on_packet_handler(Box::new(  in handle_play()
431                                 let mut bytes_writer = AsyncBytesWriter::new(io);  in handle_play()
443                     track.rtp_channel.lock().await.on_packet_handler(Box::new(  in handle_play()
446                                 let mut bytes_writer = AsyncBytesWriter::new(io);  in handle_play()
615                     let track = RtspTrack::new(TrackType::Audio, codec_info, media_control);  in new_tracks()
629                     let track = RtspTrack::new(TrackType::Video, codec_info, media_control);  in new_tracks()
665             Uuid::new(RandomDigitCount::Zero)  in get_subscriber_info()
683             Uuid::new(RandomDigitCount::Zero)  in get_publisher_info()
711     pub fn new() -> Self {  in new()  method
713             sdp: Mutex::new(Sdp::default()),  in new()
745                     let mut bytes_writer = BytesWriter::new();  in send_prior_data()