diff --git a/crates/openshell-server/src/multiplex.rs b/crates/openshell-server/src/multiplex.rs index 46223f497..f4faa0867 100644 --- a/crates/openshell-server/src/multiplex.rs +++ b/crates/openshell-server/src/multiplex.rs @@ -305,7 +305,7 @@ impl GrpcRateLimitService { impl tower::Service> for GrpcRateLimitService where - S: tower::Service, Response = Response>, + S: tower::Service, Response = Response>, S::Future: Send + 'static, B: Send + 'static, { @@ -953,7 +953,7 @@ mod tests { } impl Service> for CountingGrpcService { - type Response = Response; + type Response = Response; type Error = std::convert::Infallible; type Future = std::future::Ready>; @@ -963,7 +963,7 @@ mod tests { fn call(&mut self, _req: Request<()>) -> Self::Future { self.calls.fetch_add(1, Ordering::Relaxed); - std::future::ready(Ok(Response::new(tonic::body::empty_body()))) + std::future::ready(Ok(Response::new(tonic::body::Body::empty()))) } } @@ -985,7 +985,7 @@ mod tests { } impl Service> for PendingInnerService { - type Response = Response; + type Response = Response; type Error = std::convert::Infallible; type Future = std::future::Ready>; @@ -995,7 +995,7 @@ mod tests { fn call(&mut self, _req: Request<()>) -> Self::Future { self.calls.fetch_add(1, Ordering::Relaxed); - std::future::ready(Ok(Response::new(tonic::body::empty_body()))) + std::future::ready(Ok(Response::new(tonic::body::Body::empty()))) } }