Skip to content

Commit bffd780

Browse files
robberphexrobberphex
committed
format
1 parent 87da038 commit bffd780

File tree

1 file changed

+55
-116
lines changed

1 file changed

+55
-116
lines changed

‎examples/echo/src/protos/hello_echo.rs

+55-116
Original file line numberDiff line numberDiff line change
@@ -18,13 +18,13 @@
1818
/// EchoRequest is the request for echo.
1919
#[derive(Clone, PartialEq, ::prost::Message)]
2020
pub struct EchoRequest {
21-
#[prost(string, tag="1")]
21+
#[prost(string, tag = "1")]
2222
pub message: ::prost::alloc::string::String,
2323
}
2424
/// EchoResponse is the response for echo.
2525
#[derive(Clone, PartialEq, ::prost::Message)]
2626
pub struct EchoResponse {
27-
#[prost(string, tag="1")]
27+
#[prost(string, tag = "1")]
2828
pub message: ::prost::alloc::string::String,
2929
}
3030
/// Generated client implementations.
@@ -64,24 +64,18 @@ pub mod echo_client {
6464
&mut self,
6565
request: Request<super::EchoRequest>,
6666
) -> Result<Response<super::EchoResponse>, dubbo::status::Status> {
67-
let codec = dubbo::codegen::ProstCodec::<
68-
super::EchoRequest,
69-
super::EchoResponse,
70-
>::default();
71-
let path = http::uri::PathAndQuery::from_static(
72-
"/grpc.examples.echo.Echo/UnaryEcho",
73-
);
67+
let codec =
68+
dubbo::codegen::ProstCodec::<super::EchoRequest, super::EchoResponse>::default();
69+
let path = http::uri::PathAndQuery::from_static("/grpc.examples.echo.Echo/UnaryEcho");
7470
self.inner.unary(request, codec, path).await
7571
}
7672
/// ServerStreamingEcho is server side streaming.
7773
pub async fn server_streaming_echo(
7874
&mut self,
7975
request: Request<super::EchoRequest>,
8076
) -> Result<Response<Decoding<super::EchoResponse>>, dubbo::status::Status> {
81-
let codec = dubbo::codegen::ProstCodec::<
82-
super::EchoRequest,
83-
super::EchoResponse,
84-
>::default();
77+
let codec =
78+
dubbo::codegen::ProstCodec::<super::EchoRequest, super::EchoResponse>::default();
8579
let path = http::uri::PathAndQuery::from_static(
8680
"/grpc.examples.echo.Echo/ServerStreamingEcho",
8781
);
@@ -92,10 +86,8 @@ pub mod echo_client {
9286
&mut self,
9387
request: impl IntoStreamingRequest<Message = super::EchoRequest>,
9488
) -> Result<Response<super::EchoResponse>, dubbo::status::Status> {
95-
let codec = dubbo::codegen::ProstCodec::<
96-
super::EchoRequest,
97-
super::EchoResponse,
98-
>::default();
89+
let codec =
90+
dubbo::codegen::ProstCodec::<super::EchoRequest, super::EchoResponse>::default();
9991
let path = http::uri::PathAndQuery::from_static(
10092
"/grpc.examples.echo.Echo/ClientStreamingEcho",
10193
);
@@ -106,10 +98,8 @@ pub mod echo_client {
10698
&mut self,
10799
request: impl IntoStreamingRequest<Message = super::EchoRequest>,
108100
) -> Result<Response<Decoding<super::EchoResponse>>, dubbo::status::Status> {
109-
let codec = dubbo::codegen::ProstCodec::<
110-
super::EchoRequest,
111-
super::EchoResponse,
112-
>::default();
101+
let codec =
102+
dubbo::codegen::ProstCodec::<super::EchoRequest, super::EchoResponse>::default();
113103
let path = http::uri::PathAndQuery::from_static(
114104
"/grpc.examples.echo.Echo/BidirectionalStreamingEcho",
115105
);
@@ -130,9 +120,7 @@ pub mod echo_server {
130120
request: Request<super::EchoRequest>,
131121
) -> Result<Response<super::EchoResponse>, dubbo::status::Status>;
132122
///Server streaming response type for the ServerStreamingEcho method.
133-
type ServerStreamingEchoStream: futures_util::Stream<
134-
Item = Result<super::EchoResponse, dubbo::status::Status>,
135-
>
123+
type ServerStreamingEchoStream: futures_util::Stream<Item = Result<super::EchoResponse, dubbo::status::Status>>
136124
+ Send
137125
+ 'static;
138126
/// ServerStreamingEcho is server side streaming.
@@ -146,19 +134,14 @@ pub mod echo_server {
146134
request: Request<Decoding<super::EchoRequest>>,
147135
) -> Result<Response<super::EchoResponse>, dubbo::status::Status>;
148136
///Server streaming response type for the BidirectionalStreamingEcho method.
149-
type BidirectionalStreamingEchoStream: futures_util::Stream<
150-
Item = Result<super::EchoResponse, dubbo::status::Status>,
151-
>
137+
type BidirectionalStreamingEchoStream: futures_util::Stream<Item = Result<super::EchoResponse, dubbo::status::Status>>
152138
+ Send
153139
+ 'static;
154140
/// BidirectionalStreamingEcho is bidi streaming.
155141
async fn bidirectional_streaming_echo(
156142
&self,
157143
request: Request<Decoding<super::EchoRequest>>,
158-
) -> Result<
159-
Response<Self::BidirectionalStreamingEchoStream>,
160-
dubbo::status::Status,
161-
>;
144+
) -> Result<Response<Self::BidirectionalStreamingEchoStream>, dubbo::status::Status>;
162145
}
163146
/// Echo is the echo service.
164147
#[derive(Debug)]
@@ -188,10 +171,7 @@ pub mod echo_server {
188171
type Response = http::Response<BoxBody>;
189172
type Error = std::convert::Infallible;
190173
type Future = BoxFuture<Self::Response, Self::Error>;
191-
fn poll_ready(
192-
&mut self,
193-
_cx: &mut Context<'_>,
194-
) -> Poll<Result<(), Self::Error>> {
174+
fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
195175
Poll::Ready(Ok(()))
196176
}
197177
fn call(&mut self, req: http::Request<B>) -> Self::Future {
@@ -204,26 +184,18 @@ pub mod echo_server {
204184
}
205185
impl<T: Echo> UnarySvc<super::EchoRequest> for UnaryEchoServer<T> {
206186
type Response = super::EchoResponse;
207-
type Future = BoxFuture<
208-
Response<Self::Response>,
209-
dubbo::status::Status,
210-
>;
211-
fn call(
212-
&mut self,
213-
request: Request<super::EchoRequest>,
214-
) -> Self::Future {
187+
type Future = BoxFuture<Response<Self::Response>, dubbo::status::Status>;
188+
fn call(&mut self, request: Request<super::EchoRequest>) -> Self::Future {
215189
let inner = self.inner.0.clone();
216190
let fut = async move { inner.unary_echo(request).await };
217191
Box::pin(fut)
218192
}
219193
}
220194
let fut = async move {
221-
let mut server = TripleServer::new(
222-
dubbo::codegen::ProstCodec::<
223-
super::EchoResponse,
224-
super::EchoRequest,
225-
>::default(),
226-
);
195+
let mut server = TripleServer::new(dubbo::codegen::ProstCodec::<
196+
super::EchoResponse,
197+
super::EchoRequest,
198+
>::default());
227199
let res = server.unary(UnaryEchoServer { inner }, req).await;
228200
Ok(res)
229201
};
@@ -234,32 +206,22 @@ pub mod echo_server {
234206
struct ServerStreamingEchoServer<T: Echo> {
235207
inner: _Inner<T>,
236208
}
237-
impl<T: Echo> ServerStreamingSvc<super::EchoRequest>
238-
for ServerStreamingEchoServer<T> {
209+
impl<T: Echo> ServerStreamingSvc<super::EchoRequest> for ServerStreamingEchoServer<T> {
239210
type Response = super::EchoResponse;
240211
type ResponseStream = T::ServerStreamingEchoStream;
241-
type Future = BoxFuture<
242-
Response<Self::ResponseStream>,
243-
dubbo::status::Status,
244-
>;
245-
fn call(
246-
&mut self,
247-
request: Request<super::EchoRequest>,
248-
) -> Self::Future {
212+
type Future =
213+
BoxFuture<Response<Self::ResponseStream>, dubbo::status::Status>;
214+
fn call(&mut self, request: Request<super::EchoRequest>) -> Self::Future {
249215
let inner = self.inner.0.clone();
250-
let fut = async move {
251-
inner.server_streaming_echo(request).await
252-
};
216+
let fut = async move { inner.server_streaming_echo(request).await };
253217
Box::pin(fut)
254218
}
255219
}
256220
let fut = async move {
257-
let mut server = TripleServer::new(
258-
dubbo::codegen::ProstCodec::<
259-
super::EchoResponse,
260-
super::EchoRequest,
261-
>::default(),
262-
);
221+
let mut server = TripleServer::new(dubbo::codegen::ProstCodec::<
222+
super::EchoResponse,
223+
super::EchoRequest,
224+
>::default());
263225
let res = server
264226
.server_streaming(ServerStreamingEchoServer { inner }, req)
265227
.await;
@@ -272,31 +234,23 @@ pub mod echo_server {
272234
struct ClientStreamingEchoServer<T: Echo> {
273235
inner: _Inner<T>,
274236
}
275-
impl<T: Echo> ClientStreamingSvc<super::EchoRequest>
276-
for ClientStreamingEchoServer<T> {
237+
impl<T: Echo> ClientStreamingSvc<super::EchoRequest> for ClientStreamingEchoServer<T> {
277238
type Response = super::EchoResponse;
278-
type Future = BoxFuture<
279-
Response<Self::Response>,
280-
dubbo::status::Status,
281-
>;
239+
type Future = BoxFuture<Response<Self::Response>, dubbo::status::Status>;
282240
fn call(
283241
&mut self,
284242
request: Request<Decoding<super::EchoRequest>>,
285243
) -> Self::Future {
286244
let inner = self.inner.0.clone();
287-
let fut = async move {
288-
inner.client_streaming_echo(request).await
289-
};
245+
let fut = async move { inner.client_streaming_echo(request).await };
290246
Box::pin(fut)
291247
}
292248
}
293249
let fut = async move {
294-
let mut server = TripleServer::new(
295-
dubbo::codegen::ProstCodec::<
296-
super::EchoResponse,
297-
super::EchoRequest,
298-
>::default(),
299-
);
250+
let mut server = TripleServer::new(dubbo::codegen::ProstCodec::<
251+
super::EchoResponse,
252+
super::EchoRequest,
253+
>::default());
300254
let res = server
301255
.client_streaming(ClientStreamingEchoServer { inner }, req)
302256
.await;
@@ -309,56 +263,41 @@ pub mod echo_server {
309263
struct BidirectionalStreamingEchoServer<T: Echo> {
310264
inner: _Inner<T>,
311265
}
312-
impl<T: Echo> StreamingSvc<super::EchoRequest>
313-
for BidirectionalStreamingEchoServer<T> {
266+
impl<T: Echo> StreamingSvc<super::EchoRequest> for BidirectionalStreamingEchoServer<T> {
314267
type Response = super::EchoResponse;
315268
type ResponseStream = T::BidirectionalStreamingEchoStream;
316-
type Future = BoxFuture<
317-
Response<Self::ResponseStream>,
318-
dubbo::status::Status,
319-
>;
269+
type Future =
270+
BoxFuture<Response<Self::ResponseStream>, dubbo::status::Status>;
320271
fn call(
321272
&mut self,
322273
request: Request<Decoding<super::EchoRequest>>,
323274
) -> Self::Future {
324275
let inner = self.inner.0.clone();
325-
let fut = async move {
326-
inner.bidirectional_streaming_echo(request).await
327-
};
276+
let fut =
277+
async move { inner.bidirectional_streaming_echo(request).await };
328278
Box::pin(fut)
329279
}
330280
}
331281
let fut = async move {
332-
let mut server = TripleServer::new(
333-
dubbo::codegen::ProstCodec::<
334-
super::EchoResponse,
335-
super::EchoRequest,
336-
>::default(),
337-
);
282+
let mut server = TripleServer::new(dubbo::codegen::ProstCodec::<
283+
super::EchoResponse,
284+
super::EchoRequest,
285+
>::default());
338286
let res = server
339-
.bidi_streaming(
340-
BidirectionalStreamingEchoServer {
341-
inner,
342-
},
343-
req,
344-
)
287+
.bidi_streaming(BidirectionalStreamingEchoServer { inner }, req)
345288
.await;
346289
Ok(res)
347290
};
348291
Box::pin(fut)
349292
}
350-
_ => {
351-
Box::pin(async move {
352-
Ok(
353-
http::Response::builder()
354-
.status(200)
355-
.header("grpc-status", "12")
356-
.header("content-type", "application/grpc")
357-
.body(empty_body())
358-
.unwrap(),
359-
)
360-
})
361-
}
293+
_ => Box::pin(async move {
294+
Ok(http::Response::builder()
295+
.status(200)
296+
.header("grpc-status", "12")
297+
.header("content-type", "application/grpc")
298+
.body(empty_body())
299+
.unwrap())
300+
}),
362301
}
363302
}
364303
}

0 commit comments

Comments
 (0)