Searched refs:push_client_session (Results 1 – 1 of 1) sorted by relevance
87 let mut push_client_session = ClientSession::new( in main() localVariable97 push_client_session.subscribe(pull_parser.app_name, pull_parser.stream_name); in main()99 if let Err(err) = push_client_session.run().await { in main()