| /xiu/application/xiu/src/ |
| H A D | api.rs | 19 id: String, field
73 async fn kick_off_client(&self, id: KickOffClient) -> Result<String> { in kick_off_client()
74 let id_result = Uuid::from_str2(&id.id); in kick_off_client()
76 if let Some(id) = id_result { in kick_off_client()
77 let hub_event = define::StreamHubEvent::ApiKickClient { id }; in kick_off_client()
105 let kick = move |Json(id): Json<KickOffClient>| async move { in run()
106 match kick_off.kick_off_client(id).await { in run()
|
| /xiu/library/streamhub/src/ |
| H A D | define.rs | 63 pub id: Uuid, field
77 state.serialize_field("id", &self.id.to_string())?; in serialize()
86 pub id: Uuid, field
100 state.serialize_field("id", &self.id.to_string())?; in serialize()
241 ApiKickClient { id: Uuid },
|
| H A D | utils.rs | 116 let id = Uuid::new(super::RandomDigitCount::Four); in test_uuid() localVariable
118 let s = id.to_string(); in test_uuid()
|
| H A D | lib.rs | 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()
195 packet_senders.lock().await.remove(&info.id); in receive_event_loop()
198 frame_senders.lock().await.remove(&info.id); in receive_event_loop()
393 .insert(info.id, PubSubInfo::Publish { identifier }); in event_loop()
429 let sub_id = info.id; in event_loop()
501 StreamHubEvent::ApiKickClient { id } => { in event_loop()
502 self.api_kick_off_client(id); in event_loop()
|
| /xiu/protocol/hls/src/ |
| H A D | flv_data_receiver.rs | 102 id: self.subscriber_id, in subscribe_from_rtmp_channels()
143 id: self.subscriber_id, in unsubscribe_from_rtmp_channels()
|
| /xiu/protocol/httpflv/src/ |
| H A D | httpflv.rs | 141 id: self.subscriber_id, in unsubscribe_from_rtmp_channels()
168 id: self.subscriber_id, in subscribe_from_rtmp_channels()
|
| /xiu/protocol/webrtc/src/session/ |
| H A D | mod.rs | 434 let id = if let Some(session_id) = &self.session_id { in get_subscriber_info() localVariable
441 id, in get_subscriber_info()
452 let id = if let Some(session_id) = &self.session_id { in get_publisher_info() localVariable
459 id, in get_publisher_info()
|
| /xiu/library/container/flv/src/ |
| H A D | mpeg4_aac.rs | 406 let id = 0; // 0-MPEG4/1-MPEG2 in adts_save() localVariable
410 0xF0 /* 12-syncword */ | (id << 3)/*1-ID*/| 0x01, /*1-protection_absent*/ in adts_save()
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | rtsp2rtmp.rs | 122 id: self.subscribe_id, in subscribe_rtsp()
152 id: self.subscribe_id, in unsubscribe_rtsp()
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 662 let id = if let Some(session_id) = &self.session_id { in get_subscriber_info() localVariable
669 id, in get_subscriber_info()
680 let id = if let Some(session_id) = &self.session_id { in get_publisher_info() localVariable
687 id, in get_publisher_info()
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | common.rs | 259 id: sub_id, in get_subscriber_info()
284 id: sub_id, in get_publisher_info()
|
| /xiu/protocol/rtmp/ |
| H A D | README.md | 136 - Improve subscriber id;
|