Home
last modified time | relevance | path

Searched refs:Ok (Results 1 – 25 of 139) sorted by relevance

123456

/tonic/tonic/src/codec/
H A Ddecode.rs153 return Ok(None); in decode_chunk()
244 Ok(None) in decode_chunk()
266 Ok(None) in poll_frame()
273 Ok(Some(())) in poll_frame()
281 Ok(None) in poll_frame()
296 Ok(()) in response()
331 Some(Ok(m)) => Ok(Some(m)), in message()
333 None => Ok(None), in message()
369 Ok(None) in trailers()
381 None => Ok(None), in decode_chunk()
[all …]
H A Dencode.rs102 return Poll::Ready(Some(Ok(buf.split_to(buf.len()).freeze()))); in poll_next()
104 Poll::Ready(Some(Ok(item))) => { in poll_next()
118 return Poll::Ready(Some(Ok(buf.split_to(buf.len()).freeze()))); in poll_next()
126 return Poll::Ready(Some(Ok(buf.split_to(buf.len()).freeze()))); in poll_next()
206 Ok(()) in finish_encoding()
321 Some(Ok(d)) => Some(Ok(Frame::data(d))).into(), in poll_frame()
326 Some(Ok(Frame::trailers(status.to_header_map()?))).into() in poll_frame()
/tonic/tests/compression/src/
H A Dlib.rs52 Ok(self.prepare_response(Response::new(SomeData { in compress_output_unary()
59 Ok(Response::new(())) in compress_input_unary()
72 .map(Ok::<_, Status>); in compress_output_server_stream()
73 Ok(self.prepare_response(Response::new(Box::pin(stream)))) in compress_output_server_stream()
84 Ok(self.prepare_response(Response::new(()))) in compress_input_client_stream()
98 Ok(self.prepare_response(Response::new(SomeData { in compress_output_client_stream()
118 .map(Ok::<_, Status>); in compress_input_output_bidirectional_stream()
119 Ok(self.prepare_response(Response::new(Box::pin(stream)))) in compress_input_output_bidirectional_stream()
/tonic/examples/src/interceptor/
H A Dclient.rs30 Ok(()) in main()
38 Ok(req) in intercept()
47 Ok(request) in call()
60 Ok(()) in using_named_interceptor()
75 Ok(()) in using_function_pointer_interceptro()
H A Dserver.rs25 Ok(Response::new(reply)) in say_hello()
43 Ok(()) in main()
57 Ok(req) in intercept()
/tonic/examples/src/streaming/
H A Dserver.rs64 match tx.send(Result::<_, Status>::Ok(item)).await { in server_streaming_echo()
65 Ok(_) => { in server_streaming_echo()
78 Ok(Response::new( in server_streaming_echo()
108 Ok(v) => tx in bidirectional_streaming_echo()
109 .send(Ok(EchoResponse { message: v.message })) in bidirectional_streaming_echo()
123 Ok(_) => (), in bidirectional_streaming_echo()
135 Ok(Response::new( in bidirectional_streaming_echo()
150 Ok(()) in main()
/tonic/examples/src/cancellation/
H A Dclient.rs20 Ok(response) => response?, in main()
23 return Ok(()); in main()
29 Ok(()) in main()
/tonic/interop/src/
H A Dserver.rs28 Ok(Response::new(Empty {})) in empty_call()
54 Ok(Response::new(res)) in unary_call()
81 Ok(Response::new( in streaming_output_call()
101 Ok(Response::new(res)) in streaming_input_call()
118 let single_message = tokio_stream::once(Ok(first_msg)); in full_duplex_call()
137 Ok(Response::new(Box::pin(stream) as Self::FullDuplexCallStream)) in full_duplex_call()
140 Ok(Response::new(Box::pin(stream) as Self::FullDuplexCallStream)) in full_duplex_call()
193 Ok(()).into() in poll_ready()
214 Ok(res in call()
215 .map(|b| b.with_trailers(async move { echo_trailer.map(Ok) })) in call()
[all …]
/tonic/examples/src/richer-error/
H A Dclient.rs24 Ok(response) => response, in main()
45 return Ok(()); in main()
51 Ok(()) in main()
H A Dclient_vec.rs24 Ok(response) => response, in main()
51 return Ok(()); in main()
57 Ok(()) in main()
/tonic/tonic-reflection/src/server/
H A Dmod.rs84 Ok(v1::ServerReflectionServer::new( in build_v1()
103 Ok(v1alpha::ServerReflectionServer::new( in build_v1alpha()
157 Ok(state) in new()
188 Ok(()) in process_file()
217 Ok(()) in process_message()
234 Ok(()) in process_enum()
245 Ok(()) in process_field()
261 Ok(encoded_fd) in symbol_by_name()
275 Ok(encoded_fd) in file_by_filename()
293 Ok(name.to_string()) in extract_name()
[all …]
H A Dv1alpha.rs37 let Ok(req) = req else { in server_reflection_info() localVariable
62 Ok(MessageResponse::AllExtensionNumbersResponse( in server_reflection_info()
67 Ok(MessageResponse::ListServicesResponse(ListServiceResponse { in server_reflection_info()
79 Ok(resp_msg) => { in server_reflection_info()
85 resp_tx.send(Ok(resp)).await.expect("send"); in server_reflection_info()
95 Ok(Response::new(ServerReflectionInfoStream::new(resp_rx))) in server_reflection_info()
H A Dv1.rs37 let Ok(req) = req else { in server_reflection_info() localVariable
62 Ok(MessageResponse::AllExtensionNumbersResponse( in server_reflection_info()
67 Ok(MessageResponse::ListServicesResponse(ListServiceResponse { in server_reflection_info()
79 Ok(resp_msg) => { in server_reflection_info()
85 resp_tx.send(Ok(resp)).await.expect("send"); in server_reflection_info()
95 Ok(Response::new(ServerReflectionInfoStream::new(resp_rx))) in server_reflection_info()
/tonic/tonic-web/src/
H A Dcall.rs147 return Ok(None); in decode_chunk()
191 Some(Ok(_)) => { in poll_decode()
223 Some(Ok(frame)) if frame.is_data() => { in poll_encode()
231 Poll::Ready(Some(Ok(Frame::data(res)))) in poll_encode()
233 Some(Ok(frame)) if frame.is_trailers() => { in poll_encode()
299 Ok(Some(trailers)) => { in poll_frame()
392 return Ok(None); in decode_trailers_frame()
443 Ok(Some(map)) in decode_trailers_frame()
471 return Ok(FindTrailers::Done(len)); in find_trailers()
477 return Ok(FindTrailers::Trailer(len)); in find_trailers()
[all …]
/tonic/examples/src/mock/
H A Dmock.rs27 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in main()
40 Ok(TokioIo::new(client)) in main()
58 Ok(()) in main()
75 Ok(Response::new(reply)) in say_hello()
/tonic/tonic/src/transport/server/
H A Dio_stream.rs56 Some(Ok(io)) => Poll::Ready(Some(Ok(ServerIo::new_io(io)))), in poll_next_without_tls()
97 Ok(ServerIo::new_tls_io(io)) in poll_next()
103 SelectOutput::Io(io) => Poll::Ready(Some(Ok(io))), in poll_next()
154 Ok(Some(stream)) => SelectOutput::Incoming(stream), in select()
155 Ok(None) => SelectOutput::Done, in select()
168 Ok(Ok(io)) => SelectOutput::Io(io), in select()
169 Ok(Err(e)) => SelectOutput::TlsErr(e), in select()
/tonic/tests/web/src/
H A Dlib.rs24 Ok(Response::new(Output { in unary_call()
39 Ok(Response::new(Box::pin(stream::iter(vec![1, 2]).map( in server_stream()
41 Ok(Output { in server_stream()
58 Ok(Response::new( in client_stream()
/tonic/examples/src/routeguide/
H A Dclient.rs38 Ok(()) in print_features()
54 Ok(response) => println!("SUMMARY: {:?}", response.into_inner()), in run_record_route()
58 Ok(()) in run_record_route()
89 Ok(()) in run_route_chat()
114 Ok(()) in main()
H A Dserver.rs32 return Ok(Response::new(feature.clone())); in get_feature()
36 Ok(Response::new(Feature::default())) in get_feature()
54 tx.send(Ok(feature.clone())).await.unwrap(); in list_features()
61 Ok(Response::new(ReceiverStream::new(rx))) in list_features()
101 Ok(Response::new(summary)) in record_route()
130 Ok(Response::new(Box::pin(output) as Self::RouteChatStream)) in route_chat()
148 Ok(()) in main()
/tonic/examples/src/authentication/
H A Dserver.rs17 Ok(Response::new(EchoResponse { message })) in unary_echo()
30 Ok(()) in main()
37 Some(t) if token == t => Ok(req), in check_auth()
H A Dclient.rs16 Ok(req) in main()
27 Ok(()) in main()
/tonic/tests/integration_tests/tests/
H A Droutes_builder.rs24 Ok(Response::new(Output {})) in multiple_service_using_routes_builder()
33 Ok(Response::new(Output1 { in multiple_service_using_routes_builder()
47 let stream = tokio_stream::once(Ok(output)); in multiple_service_using_routes_builder()
49 Ok(Response::new(Box::pin(stream))) in multiple_service_using_routes_builder()
101 Some(Ok(first)) => first, in multiple_service_using_routes_builder()
H A Dmax_message_size.rs141 let stream = tokio_stream::iter(vec![Ok(blob.clone()), Ok(blob.clone())]); in response_stream_limit()
143 Ok(Response::new(Box::pin(stream))) in response_stream_limit()
152 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in response_stream_limit()
167 Ok(TokioIo::new(client)) in response_stream_limit()
245 (Some(_), Ok(())) => panic!("Expected failure, but got success"), in assert_test_case()
285 Ok(Response::new(Output1 { in max_message_run()
318 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in max_message_run()
333 Ok(TokioIo::new(client)) in max_message_run()
/tonic/examples/src/multiplex/
H A Dserver.rs34 Ok(()) in main()
49 Ok(Response::new(reply)) in say_hello()
63 Ok(Response::new(EchoResponse { message })) in unary_echo()
/tonic/examples/src/tower/
H A Dserver.rs29 Ok(Response::new(reply)) in say_hello()
57 Ok(()) in main()
62 Ok(req) in intercept()
106 Ok(response) in call()

123456