Searched refs:subscribe (Results 1 – 5 of 5) sorted by relevance
3 - Support subscribe/publish RTSP stream
230 tx.subscribe(), in run()239 tx.subscribe(), in run()325 self.client_event_producer.subscribe() in get_client_event_consumer()460 let rv = match self.subscribe(&identifier, info_clone, sender).await { in event_loop()593 pub async fn subscribe( in subscribe() method
97 push_client_session.subscribe(pull_parser.app_name, pull_parser.stream_name); in main()
119 let mut state_receiver = state_sender.subscribe(); in handle_whep()
568 pub fn subscribe(&mut self, app_name: String, stream_name: String) { in subscribe() method