172                         TransmitterEvent::Subscribe { sender, info } => {  in receive_event_loop()
174                                 .send_prior_data(sender.clone(), info.sub_type)  in receive_event_loop()
184                                     frame_senders.lock().await.insert(info.id, frame_sender);  in receive_event_loop()
189                                     packet_senders.lock().await.insert(info.id, packet_sender);  in receive_event_loop()
193                         TransmitterEvent::UnSubscribe { info } => match info.sub_type {  in receive_event_loop()
195                                 packet_senders.lock().await.remove(&info.id);  in receive_event_loop()
198                                 frame_senders.lock().await.remove(&info.id);  in receive_event_loop()
212                                     log::info!("Transmitter send avstatistic data err: {}", err);  in receive_event_loop()
331                 log::info!("event data: {}", data);  in event_loop()
340                     info,  in event_loop()
344                     let (frame_sender, packet_sender, receiver) = match info.pub_data_type {  in event_loop()
393                                 .insert(info.id, PubSubInfo::Publish { identifier });  in event_loop()
410                     info: _,  in event_loop()
426                     info,  in event_loop()
429                     let sub_id = info.id;  in event_loop()
430                     let info_clone = info.clone();  in event_loop()
433                     let (sender, receiver) = match info.sub_data_type {  in event_loop()
470                                     sub_info: info,  in event_loop()
485                 StreamHubEvent::UnSubscribe { identifier, info } => {  in event_loop()
486                     if self.unsubscribe(&identifier, info).is_ok() {  in event_loop()
524             log::info!("Request:  stream identifier: {}", identifier);  in request()
561         let info = if let Some(info) = self.streams_info.get(&uid) {  in api_kick_off_client()  localVariable
562             info.clone()  in api_kick_off_client()
567         match info {  in api_kick_off_client()
602                 info: sub_info,  in subscribe()
604             log::info!("subscribe:  stream identifier: {}", identifer);  in subscribe()
613             log::info!("subscribe: try to pull stream, identifier: {}", identifer);  in subscribe()
639                 log::info!("unsubscribe....:{}", identifer);  in unsubscribe()
640                 let event = TransmitterEvent::UnSubscribe { info: sub_info };  in unsubscribe()
680             log::info!("transmiter exits: idetifier: {}", identifier_clone);  in publish()
707                 log::info!("unpublish remove stream, stream identifier: {}", identifier);  in unpublish()