Skip to content

Commit 4fea4e4

Browse files
oneweonewe
committed
cargo fmt
1 parent c2d1566 commit 4fea4e4

File tree

1 file changed

+37
-90
lines changed

1 file changed

+37
-90
lines changed

‎examples/echo/src/generated/grpc.examples.echo.rs

+37-90
Original file line numberDiff line numberDiff line change
@@ -43,9 +43,7 @@ pub mod echo_client {
4343
let invocation = RpcInvocation::default()
4444
.with_service_unique_name(String::from("grpc.examples.echo.Echo"))
4545
.with_method_name(String::from("UnaryEcho"));
46-
let path = http::uri::PathAndQuery::from_static(
47-
"/grpc.examples.echo.Echo/UnaryEcho",
48-
);
46+
let path = http::uri::PathAndQuery::from_static("/grpc.examples.echo.Echo/UnaryEcho");
4947
self.inner.unary(request, path, invocation).await
5048
}
5149
/// ServerStreamingEcho is server side streaming.
@@ -102,9 +100,7 @@ pub mod echo_server {
102100
request: Request<super::EchoRequest>,
103101
) -> Result<Response<super::EchoResponse>, dubbo::status::Status>;
104102
///Server streaming response type for the ServerStreamingEcho method.
105-
type ServerStreamingEchoStream: futures_util::Stream<
106-
Item = Result<super::EchoResponse, dubbo::status::Status>,
107-
>
103+
type ServerStreamingEchoStream: futures_util::Stream<Item = Result<super::EchoResponse, dubbo::status::Status>>
108104
+ Send
109105
+ 'static;
110106
/// ServerStreamingEcho is server side streaming.
@@ -118,19 +114,14 @@ pub mod echo_server {
118114
request: Request<Decoding<super::EchoRequest>>,
119115
) -> Result<Response<super::EchoResponse>, dubbo::status::Status>;
120116
///Server streaming response type for the BidirectionalStreamingEcho method.
121-
type BidirectionalStreamingEchoStream: futures_util::Stream<
122-
Item = Result<super::EchoResponse, dubbo::status::Status>,
123-
>
117+
type BidirectionalStreamingEchoStream: futures_util::Stream<Item = Result<super::EchoResponse, dubbo::status::Status>>
124118
+ Send
125119
+ 'static;
126120
/// BidirectionalStreamingEcho is bidi streaming.
127121
async fn bidirectional_streaming_echo(
128122
&self,
129123
request: Request<Decoding<super::EchoRequest>>,
130-
) -> Result<
131-
Response<Self::BidirectionalStreamingEchoStream>,
132-
dubbo::status::Status,
133-
>;
124+
) -> Result<Response<Self::BidirectionalStreamingEchoStream>, dubbo::status::Status>;
134125
}
135126
/// Echo is the echo service.
136127
#[derive(Debug)]
@@ -160,10 +151,7 @@ pub mod echo_server {
160151
type Response = http::Response<BoxBody>;
161152
type Error = std::convert::Infallible;
162153
type Future = BoxFuture<Self::Response, Self::Error>;
163-
fn poll_ready(
164-
&mut self,
165-
_cx: &mut Context<'_>,
166-
) -> Poll<Result<(), Self::Error>> {
154+
fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
167155
Poll::Ready(Ok(()))
168156
}
169157
fn call(&mut self, req: http::Request<B>) -> Self::Future {
@@ -176,24 +164,16 @@ pub mod echo_server {
176164
}
177165
impl<T: Echo> UnarySvc<super::EchoRequest> for UnaryEchoServer<T> {
178166
type Response = super::EchoResponse;
179-
type Future = BoxFuture<
180-
Response<Self::Response>,
181-
dubbo::status::Status,
182-
>;
183-
fn call(
184-
&mut self,
185-
request: Request<super::EchoRequest>,
186-
) -> Self::Future {
167+
type Future = BoxFuture<Response<Self::Response>, dubbo::status::Status>;
168+
fn call(&mut self, request: Request<super::EchoRequest>) -> Self::Future {
187169
let inner = self.inner.0.clone();
188170
let fut = async move { inner.unary_echo(request).await };
189171
Box::pin(fut)
190172
}
191173
}
192174
let fut = async move {
193-
let mut server = TripleServer::<
194-
super::EchoRequest,
195-
super::EchoResponse,
196-
>::new();
175+
let mut server =
176+
TripleServer::<super::EchoRequest, super::EchoResponse>::new();
197177
let res = server.unary(UnaryEchoServer { inner }, req).await;
198178
Ok(res)
199179
};
@@ -204,30 +184,20 @@ pub mod echo_server {
204184
struct ServerStreamingEchoServer<T: Echo> {
205185
inner: _Inner<T>,
206186
}
207-
impl<T: Echo> ServerStreamingSvc<super::EchoRequest>
208-
for ServerStreamingEchoServer<T> {
187+
impl<T: Echo> ServerStreamingSvc<super::EchoRequest> for ServerStreamingEchoServer<T> {
209188
type Response = super::EchoResponse;
210189
type ResponseStream = T::ServerStreamingEchoStream;
211-
type Future = BoxFuture<
212-
Response<Self::ResponseStream>,
213-
dubbo::status::Status,
214-
>;
215-
fn call(
216-
&mut self,
217-
request: Request<super::EchoRequest>,
218-
) -> Self::Future {
190+
type Future =
191+
BoxFuture<Response<Self::ResponseStream>, dubbo::status::Status>;
192+
fn call(&mut self, request: Request<super::EchoRequest>) -> Self::Future {
219193
let inner = self.inner.0.clone();
220-
let fut = async move {
221-
inner.server_streaming_echo(request).await
222-
};
194+
let fut = async move { inner.server_streaming_echo(request).await };
223195
Box::pin(fut)
224196
}
225197
}
226198
let fut = async move {
227-
let mut server = TripleServer::<
228-
super::EchoRequest,
229-
super::EchoResponse,
230-
>::new();
199+
let mut server =
200+
TripleServer::<super::EchoRequest, super::EchoResponse>::new();
231201
let res = server
232202
.server_streaming(ServerStreamingEchoServer { inner }, req)
233203
.await;
@@ -240,29 +210,21 @@ pub mod echo_server {
240210
struct ClientStreamingEchoServer<T: Echo> {
241211
inner: _Inner<T>,
242212
}
243-
impl<T: Echo> ClientStreamingSvc<super::EchoRequest>
244-
for ClientStreamingEchoServer<T> {
213+
impl<T: Echo> ClientStreamingSvc<super::EchoRequest> for ClientStreamingEchoServer<T> {
245214
type Response = super::EchoResponse;
246-
type Future = BoxFuture<
247-
Response<Self::Response>,
248-
dubbo::status::Status,
249-
>;
215+
type Future = BoxFuture<Response<Self::Response>, dubbo::status::Status>;
250216
fn call(
251217
&mut self,
252218
request: Request<Decoding<super::EchoRequest>>,
253219
) -> Self::Future {
254220
let inner = self.inner.0.clone();
255-
let fut = async move {
256-
inner.client_streaming_echo(request).await
257-
};
221+
let fut = async move { inner.client_streaming_echo(request).await };
258222
Box::pin(fut)
259223
}
260224
}
261225
let fut = async move {
262-
let mut server = TripleServer::<
263-
super::EchoRequest,
264-
super::EchoResponse,
265-
>::new();
226+
let mut server =
227+
TripleServer::<super::EchoRequest, super::EchoResponse>::new();
266228
let res = server
267229
.client_streaming(ClientStreamingEchoServer { inner }, req)
268230
.await;
@@ -275,54 +237,39 @@ pub mod echo_server {
275237
struct BidirectionalStreamingEchoServer<T: Echo> {
276238
inner: _Inner<T>,
277239
}
278-
impl<T: Echo> StreamingSvc<super::EchoRequest>
279-
for BidirectionalStreamingEchoServer<T> {
240+
impl<T: Echo> StreamingSvc<super::EchoRequest> for BidirectionalStreamingEchoServer<T> {
280241
type Response = super::EchoResponse;
281242
type ResponseStream = T::BidirectionalStreamingEchoStream;
282-
type Future = BoxFuture<
283-
Response<Self::ResponseStream>,
284-
dubbo::status::Status,
285-
>;
243+
type Future =
244+
BoxFuture<Response<Self::ResponseStream>, dubbo::status::Status>;
286245
fn call(
287246
&mut self,
288247
request: Request<Decoding<super::EchoRequest>>,
289248
) -> Self::Future {
290249
let inner = self.inner.0.clone();
291-
let fut = async move {
292-
inner.bidirectional_streaming_echo(request).await
293-
};
250+
let fut =
251+
async move { inner.bidirectional_streaming_echo(request).await };
294252
Box::pin(fut)
295253
}
296254
}
297255
let fut = async move {
298-
let mut server = TripleServer::<
299-
super::EchoRequest,
300-
super::EchoResponse,
301-
>::new();
256+
let mut server =
257+
TripleServer::<super::EchoRequest, super::EchoResponse>::new();
302258
let res = server
303-
.bidi_streaming(
304-
BidirectionalStreamingEchoServer {
305-
inner,
306-
},
307-
req,
308-
)
259+
.bidi_streaming(BidirectionalStreamingEchoServer { inner }, req)
309260
.await;
310261
Ok(res)
311262
};
312263
Box::pin(fut)
313264
}
314-
_ => {
315-
Box::pin(async move {
316-
Ok(
317-
http::Response::builder()
318-
.status(200)
319-
.header("grpc-status", "12")
320-
.header("content-type", "application/grpc")
321-
.body(empty_body())
322-
.unwrap(),
323-
)
324-
})
325-
}
265+
_ => Box::pin(async move {
266+
Ok(http::Response::builder()
267+
.status(200)
268+
.header("grpc-status", "12")
269+
.header("content-type", "application/grpc")
270+
.body(empty_body())
271+
.unwrap())
272+
}),
326273
}
327274
}
328275
}

0 commit comments

Comments
 (0)