style: cargo fmt
diff --git a/examples/echo/src/generated/grpc.examples.echo.rs b/examples/echo/src/generated/grpc.examples.echo.rs index ee8cc1e..fc48dc5 100644 --- a/examples/echo/src/generated/grpc.examples.echo.rs +++ b/examples/echo/src/generated/grpc.examples.echo.rs
@@ -43,9 +43,7 @@ let invocation = RpcInvocation::default() .with_service_unique_name(String::from("grpc.examples.echo.Echo")) .with_method_name(String::from("UnaryEcho")); - let path = http::uri::PathAndQuery::from_static( - "/grpc.examples.echo.Echo/UnaryEcho", - ); + let path = http::uri::PathAndQuery::from_static("/grpc.examples.echo.Echo/UnaryEcho"); self.inner.unary(request, path, invocation).await } /// ServerStreamingEcho is server side streaming. @@ -102,9 +100,7 @@ request: Request<super::EchoRequest>, ) -> Result<Response<super::EchoResponse>, dubbo::status::Status>; ///Server streaming response type for the ServerStreamingEcho method. - type ServerStreamingEchoStream: futures_util::Stream< - Item = Result<super::EchoResponse, dubbo::status::Status>, - > + type ServerStreamingEchoStream: futures_util::Stream<Item = Result<super::EchoResponse, dubbo::status::Status>> + Send + 'static; /// ServerStreamingEcho is server side streaming. @@ -118,19 +114,14 @@ request: Request<Decoding<super::EchoRequest>>, ) -> Result<Response<super::EchoResponse>, dubbo::status::Status>; ///Server streaming response type for the BidirectionalStreamingEcho method. - type BidirectionalStreamingEchoStream: futures_util::Stream< - Item = Result<super::EchoResponse, dubbo::status::Status>, - > + type BidirectionalStreamingEchoStream: futures_util::Stream<Item = Result<super::EchoResponse, dubbo::status::Status>> + Send + 'static; /// BidirectionalStreamingEcho is bidi streaming. async fn bidirectional_streaming_echo( &self, request: Request<Decoding<super::EchoRequest>>, - ) -> Result< - Response<Self::BidirectionalStreamingEchoStream>, - dubbo::status::Status, - >; + ) -> Result<Response<Self::BidirectionalStreamingEchoStream>, dubbo::status::Status>; } /// Echo is the echo service. #[derive(Debug)] @@ -160,10 +151,7 @@ type Response = http::Response<BoxBody>; type Error = std::convert::Infallible; type Future = BoxFuture<Self::Response, Self::Error>; - 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(())) } fn call(&mut self, req: http::Request<B>) -> Self::Future { @@ -176,24 +164,16 @@ } impl<T: Echo> UnarySvc<super::EchoRequest> for UnaryEchoServer<T> { type Response = super::EchoResponse; - type Future = BoxFuture< - Response<Self::Response>, - dubbo::status::Status, - >; - fn call( - &mut self, - request: Request<super::EchoRequest>, - ) -> Self::Future { + type Future = BoxFuture<Response<Self::Response>, dubbo::status::Status>; + fn call(&mut self, request: Request<super::EchoRequest>) -> Self::Future { let inner = self.inner.0.clone(); let fut = async move { inner.unary_echo(request).await }; Box::pin(fut) } } let fut = async move { - let mut server = TripleServer::< - super::EchoRequest, - super::EchoResponse, - >::new(); + let mut server = + TripleServer::<super::EchoRequest, super::EchoResponse>::new(); let res = server.unary(UnaryEchoServer { inner }, req).await; Ok(res) }; @@ -204,30 +184,20 @@ struct ServerStreamingEchoServer<T: Echo> { inner: _Inner<T>, } - impl<T: Echo> ServerStreamingSvc<super::EchoRequest> - for ServerStreamingEchoServer<T> { + impl<T: Echo> ServerStreamingSvc<super::EchoRequest> for ServerStreamingEchoServer<T> { type Response = super::EchoResponse; type ResponseStream = T::ServerStreamingEchoStream; - type Future = BoxFuture< - Response<Self::ResponseStream>, - dubbo::status::Status, - >; - fn call( - &mut self, - request: Request<super::EchoRequest>, - ) -> Self::Future { + type Future = + BoxFuture<Response<Self::ResponseStream>, dubbo::status::Status>; + fn call(&mut self, request: Request<super::EchoRequest>) -> Self::Future { let inner = self.inner.0.clone(); - let fut = async move { - inner.server_streaming_echo(request).await - }; + let fut = async move { inner.server_streaming_echo(request).await }; Box::pin(fut) } } let fut = async move { - let mut server = TripleServer::< - super::EchoRequest, - super::EchoResponse, - >::new(); + let mut server = + TripleServer::<super::EchoRequest, super::EchoResponse>::new(); let res = server .server_streaming(ServerStreamingEchoServer { inner }, req) .await; @@ -240,29 +210,21 @@ struct ClientStreamingEchoServer<T: Echo> { inner: _Inner<T>, } - impl<T: Echo> ClientStreamingSvc<super::EchoRequest> - for ClientStreamingEchoServer<T> { + impl<T: Echo> ClientStreamingSvc<super::EchoRequest> for ClientStreamingEchoServer<T> { type Response = super::EchoResponse; - type Future = BoxFuture< - Response<Self::Response>, - dubbo::status::Status, - >; + type Future = BoxFuture<Response<Self::Response>, dubbo::status::Status>; fn call( &mut self, request: Request<Decoding<super::EchoRequest>>, ) -> Self::Future { let inner = self.inner.0.clone(); - let fut = async move { - inner.client_streaming_echo(request).await - }; + let fut = async move { inner.client_streaming_echo(request).await }; Box::pin(fut) } } let fut = async move { - let mut server = TripleServer::< - super::EchoRequest, - super::EchoResponse, - >::new(); + let mut server = + TripleServer::<super::EchoRequest, super::EchoResponse>::new(); let res = server .client_streaming(ClientStreamingEchoServer { inner }, req) .await; @@ -275,54 +237,39 @@ struct BidirectionalStreamingEchoServer<T: Echo> { inner: _Inner<T>, } - impl<T: Echo> StreamingSvc<super::EchoRequest> - for BidirectionalStreamingEchoServer<T> { + impl<T: Echo> StreamingSvc<super::EchoRequest> for BidirectionalStreamingEchoServer<T> { type Response = super::EchoResponse; type ResponseStream = T::BidirectionalStreamingEchoStream; - type Future = BoxFuture< - Response<Self::ResponseStream>, - dubbo::status::Status, - >; + type Future = + BoxFuture<Response<Self::ResponseStream>, dubbo::status::Status>; fn call( &mut self, request: Request<Decoding<super::EchoRequest>>, ) -> Self::Future { let inner = self.inner.0.clone(); - let fut = async move { - inner.bidirectional_streaming_echo(request).await - }; + let fut = + async move { inner.bidirectional_streaming_echo(request).await }; Box::pin(fut) } } let fut = async move { - let mut server = TripleServer::< - super::EchoRequest, - super::EchoResponse, - >::new(); + let mut server = + TripleServer::<super::EchoRequest, super::EchoResponse>::new(); let res = server - .bidi_streaming( - BidirectionalStreamingEchoServer { - inner, - }, - req, - ) + .bidi_streaming(BidirectionalStreamingEchoServer { inner }, req) .await; Ok(res) }; Box::pin(fut) } - _ => { - Box::pin(async move { - Ok( - http::Response::builder() - .status(200) - .header("grpc-status", "12") - .header("content-type", "application/grpc") - .body(empty_body()) - .unwrap(), - ) - }) - } + _ => Box::pin(async move { + Ok(http::Response::builder() + .status(200) + .header("grpc-status", "12") + .header("content-type", "application/grpc") + .body(empty_body()) + .unwrap()) + }), } } }