Skip to content

Commit

Permalink
style: cargo fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
@yang20150702
yang20150702 committed Jul 10, 2024
1 parent 2264175 commit 0237338
Showing 1 changed file with 37 additions and 90 deletions.
127 changes: 37 additions & 90 deletions examples/echo/src/generated/grpc.examples.echo.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -43,9 +43,7 @@ pub mod echo_client {
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.
Expand Down Expand Up @@ -102,9 +100,7 @@ pub mod echo_server {
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.
Expand All @@ -118,19 +114,14 @@ pub mod echo_server {
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)]
Expand Down Expand Up @@ -160,10 +151,7 @@ pub mod echo_server {
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 {
Expand All @@ -176,24 +164,16 @@ pub mod echo_server {
}
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)
};
Expand All @@ -204,30 +184,20 @@ pub mod echo_server {
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;
Expand All @@ -240,29 +210,21 @@ pub mod echo_server {
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;
Expand All @@ -275,54 +237,39 @@ pub mod echo_server {
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())
}),
}
}
}
Expand Down

0 comments on commit 0237338

Please sign in to comment.