| /tonic/interop/src/ |
| H A D | client.rs | 26 result.is_ok(), in empty_unary() 54 result.is_ok(), in large_unary() 96 result.is_ok(), in client_streaming() 125 result.is_ok(), in server_streaming() 157 let result = client in ping_pong() localVariable 165 result.is_ok(), in ping_pong() 215 result.is_ok(), in empty_stream() 299 match &result { in special_status_message() 308 match &result { in special_status_message() 320 match &result { in unimplemented_method() [all …]
|
| H A D | server.rs | 7 use std::result::Result as StdResult;
|
| /tonic/interop/src/bin/ |
| H A D | client.rs | 89 for result in test_results { in main() 90 println!(" {}", result); in main() 92 if result.is_failed() { in main() 93 failures.push(result); in main()
|
| H A D | server.rs | 20 async fn main() -> std::result::Result<(), Box<dyn std::error::Error>> { in main()
|
| /tonic/tests/service_named_result/proto/ |
| H A D | result.proto | 5 package result; package
|
| /tonic/tonic-build/src/ |
| H A D | server.rs | 159 … fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<std::result::Result<(), Self::Error>> { in generate_internal() 269 -> std::result::Result<tonic::Response<#res_message>, tonic::Status> { in generate_trait_methods() 278 -> std::result::Result<tonic::Response<#res_message>, tonic::Status>; in generate_trait_methods() 285 -> std::result::Result<tonic::Response<#res_message>, tonic::Status> { in generate_trait_methods() 294 -> std::result::Result<tonic::Response<#res_message>, tonic::Status>; in generate_trait_methods() 301 … -> std::result::Result<tonic::Response<BoxStream<#res_message>>, tonic::Status> { in generate_trait_methods() 315 …type #stream: tonic::codegen::tokio_stream::Stream<Item = std::result::Result<#res_message, tonic:… in generate_trait_methods() 319 -> std::result::Result<tonic::Response<Self::#stream>, tonic::Status>; in generate_trait_methods() 326 … -> std::result::Result<tonic::Response<BoxStream<#res_message>>, tonic::Status> { in generate_trait_methods() 340 …type #stream: tonic::codegen::tokio_stream::Stream<Item = std::result::Result<#res_message, tonic:… in generate_trait_methods() [all …]
|
| H A D | client.rs | 239 ) -> std::result::Result<tonic::Response<#response>, tonic::Status> { in generate_unary() 270 … ) -> std::result::Result<tonic::Response<tonic::codec::Streaming<#response>>, tonic::Status> { in generate_server_streaming() 301 ) -> std::result::Result<tonic::Response<#response>, tonic::Status> { in generate_client_streaming() 332 … ) -> std::result::Result<tonic::Response<tonic::codec::Streaming<#response>>, tonic::Status> { in generate_streaming()
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 143 ) -> std::result::Result< in check() 182 ) -> std::result::Result< in watch() 223 ) -> std::result::Result< in check() 229 Item = std::result::Result<super::HealthCheckResponse, tonic::Status>, 251 ) -> std::result::Result<tonic::Response<Self::WatchStream>, tonic::Status>; in watch() 324 ) -> Poll<std::result::Result<(), Self::Error>> { in poll_ready()
|
| /tonic/tonic/src/ |
| H A D | lib.rs | 135 pub type Result<T, E = Status> = std::result::Result<T, E>;
|
| /tonic/examples/src/streaming/ |
| H A D | server.rs | 106 while let Some(result) = in_stream.next().await { in bidirectional_streaming_echo() 107 match result { in bidirectional_streaming_echo()
|
| /tonic/examples/src/blocking/ |
| H A D | client.rs | 10 type Result<T, E = StdError> = ::std::result::Result<T, E>;
|
| /tonic/tests/integration_tests/tests/ |
| H A D | streams.rs | 6 Box<dyn tokio_stream::Stream<Item = std::result::Result<T, Status>> + Send + 'static>,
|
| H A D | status.rs | 139 Box<dyn tokio_stream::Stream<Item = std::result::Result<T, Status>> + Send + 'static>,
|
| /tonic/tonic-reflection/src/generated/ |
| H A D | grpc_reflection_v1.rs | 234 ) -> std::result::Result< in server_reflection_info() 277 Item = std::result::Result< 289 ) -> std::result::Result< in server_reflection_info() 365 ) -> Poll<std::result::Result<(), Self::Error>> { in poll_ready()
|
| H A D | grpc_reflection_v1alpha.rs | 234 ) -> std::result::Result< in server_reflection_info() 277 Item = std::result::Result< 289 ) -> std::result::Result< in server_reflection_info() 365 ) -> Poll<std::result::Result<(), Self::Error>> { in poll_ready()
|
| /tonic/tonic/src/codec/ |
| H A D | prost.rs | 393 let result = if should_send { in poll_frame() localVariable 404 result in poll_frame()
|
| /tonic/tonic/src/server/ |
| H A D | grpc.rs | 17 ($result:expr) => { 18 match $result {
|
| /tonic/interop/proto/grpc/testing/ |
| H A D | test.proto | 45 // The server returns the aggregated size of client payload as the result.
|
| /tonic/examples/proto/googleapis/google/api/ |
| H A D | field_behavior.proto | 66 // *must not* throw an error as a result of the field's presence).
|
| H A D | http.proto | 297 // to invalid URLs. As the result, gRPC Transcoding uses a custom encoding
|
| /tonic/examples/proto/googleapis/google/pubsub/v1/ |
| H A D | pubsub.proto | 491 // than once will not result in an error. 1082 // more than once will not result in an error. If the acknowledgement ID is
|
| /tonic/ |
| H A D | CHANGELOG.md | 219 * add `Result<T>` type alias for `std::result::Result<T, tonic::Status>` ([#1085](https://github.co…
|