Searched refs:WatchStream (Results 1 – 2 of 2) sorted by relevance
131 type WatchStream = WatchStream; typedef136 ) -> Result<Response<Self::WatchStream>, Status> { in watch() argument143 Ok(Response::new(WatchStream::new(status_rx))) in watch()148 pub struct WatchStream { struct149 inner: tokio_stream::wrappers::WatchStream<ServingStatus>, argument152 impl WatchStream { implementation154 let inner = tokio_stream::wrappers::WatchStream::new(status_rx); in new()159 impl Stream for WatchStream { implementation172 impl fmt::Debug for WatchStream { implementation
228 type WatchStream: tonic::codegen::tokio_stream::Stream< typedef251 ) -> std::result::Result<tonic::Response<Self::WatchStream>, tonic::Status>; in watch() argument382 type ResponseStream = T::WatchStream; in call()