Lines Matching refs:stream_name

298         stream_name: String,  in subscribe_from_channels()
304             stream_name,  in subscribe_from_channels()
310             stream_name,  in subscribe_from_channels()
337         stream_name: String,  in unsubscribe_from_channels()
342             stream_name,  in unsubscribe_from_channels()
360         stream_name: String,  in publish_to_channels()
365             .set_cache(Cache::new(app_name.clone(), stream_name.clone(), gop_num))  in publish_to_channels()
372                 stream_name,  in publish_to_channels()
393         stream_name: String,  in unpublish_to_channels()
399             stream_name  in unpublish_to_channels()
404                 stream_name: stream_name.clone(),  in unpublish_to_channels()
414                     stream_name  in unpublish_to_channels()
424                     stream_name  in unpublish_to_channels()