tonic: propagate call to poll_ready in InterceptedService (#685)

Fixes: #678
This commit is contained in:
Szymon Gibała
2021-06-19 16:51:20 +02:00
committed by GitHub
parent 4e0d2fc598
commit 2ba0889553
+3 -3
View File
@@ -69,7 +69,7 @@ pub struct InterceptedService<S, F> {
} }
impl<S, F> InterceptedService<S, F> { impl<S, F> InterceptedService<S, F> {
/// Create a new `InterceptedService` thats wraps `S` and intercepts each request with the /// Create a new `InterceptedService` that wraps `S` and intercepts each request with the
/// function `F`. /// function `F`.
pub fn new(service: S, f: F) -> Self pub fn new(service: S, f: F) -> Self
where where
@@ -102,8 +102,8 @@ where
type Future = ResponseFuture<S::Future>; type Future = ResponseFuture<S::Future>;
#[inline] #[inline]
fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
Poll::Ready(Ok(())) self.inner.poll_ready(cx).map_err(Into::into)
} }
fn call(&mut self, req: http::Request<ReqBody>) -> Self::Future { fn call(&mut self, req: http::Request<ReqBody>) -> Self::Future {