Searched refs:Receiver (Results 1 – 6 of 6) sorted by relevance
8 use tokio::sync::mpsc::Receiver;22 changes: Receiver<Change<K, Endpoint>>,26 pub(crate) fn new(changes: Receiver<Change<K, Endpoint>>) -> Self { in new()
29 type StatusPair = (watch::Sender<ServingStatus>, watch::Receiver<ServingStatus>);153 fn new(status_rx: watch::Receiver<ServingStatus>) -> Self { in new()
113 fn new(resp_rx: mpsc::Receiver<Result<ServerReflectionResponse, Status>>) -> Self { in new()
88 rx: tokio::sync::mpsc::Receiver<Frame<T>>,
771 mut watcher: Option<tokio::sync::watch::Receiver<()>>, in serve_connection() argument