Searched refs:subscribe_event (Results 1 – 6 of 6) sorted by relevance
118 let subscribe_event = StreamHubEvent::Subscribe { in subscribe_from_rtmp_channels() localVariable124 let rv = self.event_producer.send(subscribe_event); in subscribe_from_rtmp_channels()157 let subscribe_event = StreamHubEvent::UnSubscribe { in unsubscribe_from_rtmp_channels() localVariable161 if let Err(err) = self.event_producer.send(subscribe_event) { in unsubscribe_from_rtmp_channels()
155 let subscribe_event = StreamHubEvent::UnSubscribe { in unsubscribe_from_rtmp_channels() localVariable159 if let Err(err) = self.event_producer.send(subscribe_event) { in unsubscribe_from_rtmp_channels()184 let subscribe_event = StreamHubEvent::Subscribe { in subscribe_from_rtmp_channels() localVariable190 let rv = self.event_producer.send(subscribe_event); in subscribe_from_rtmp_channels()
131 let subscribe_event = StreamHubEvent::Subscribe { in subscribe_rtsp() localVariable139 if self.event_producer.send(subscribe_event).is_err() { in subscribe_rtsp()161 let subscribe_event = StreamHubEvent::UnSubscribe { in unsubscribe_rtsp() localVariable167 if let Err(err) = self.event_producer.send(subscribe_event) { in unsubscribe_rtsp()
315 let subscribe_event = StreamHubEvent::Subscribe { in subscribe_from_channels() localVariable320 let rv = self.event_producer.send(subscribe_event); in subscribe_from_channels()345 let subscribe_event = StreamHubEvent::UnSubscribe { in unsubscribe_from_channels() localVariable349 if let Err(err) = self.event_producer.send(subscribe_event) { in unsubscribe_from_channels()
332 let subscribe_event = StreamHubEvent::Subscribe { in subscribe_whep() localVariable341 if self.event_sender.send(subscribe_event).is_err() { in subscribe_whep()
533 let subscribe_event = StreamHubEvent::UnSubscribe { in unsubscribe_from_stream_hub() localVariable537 if let Err(err) = self.event_producer.send(subscribe_event) { in unsubscribe_from_stream_hub()