Searched refs:status_rx (Results 1 – 1 of 1) sorted by relevance
138 let status_rx = match self.statuses.read().await.get(service_name) { in watch() localVariable143 Ok(Response::new(WatchStream::new(status_rx))) in watch()153 fn new(status_rx: watch::Receiver<ServingStatus>) -> Self { in new()154 let inner = tokio_stream::wrappers::WatchStream::new(status_rx); in new()