Searched refs:watch (Results 1 – 5 of 5) sorted by relevance
9 use tokio::sync::{watch, RwLock};29 type StatusPair = (watch::Sender<ServingStatus>, watch::Receiver<ServingStatus>);42 let server_status = ("".to_string(), watch::channel(ServingStatus::Serving)); in new()88 writer.insert(service_name.to_string(), watch::channel(status)); in set_service_status()133 async fn watch( in watch() method153 fn new(status_rx: watch::Receiver<ServingStatus>) -> Self { in new()191 use tokio::sync::watch;213 watch::channel(ServingStatus::Unknown), in make_test_service()274 .watch(Request::new(HealthCheckRequest { in test_service_watch()289 .watch(Request::new(HealthCheckRequest { in test_service_watch()[all …]
140 systemfd --no-pid -s http::[::1]:50051 -- cargo watch -x 'run --bin autoreload-server'155 * [cargo-watch](https://crates.io/crates/cargo-watch)
179 pub async fn watch( in watch() function248 async fn watch( in watch() method393 <T as Health>::watch(&inner, request).await in call()
47 // Performs a watch for the serving status of the requested service.
705 let (signal_tx, signal_rx) = tokio::sync::watch::channel(()); in serve_internal()771 mut watcher: Option<tokio::sync::watch::Receiver<()>>, in serve_connection()