| /tonic/tests/compression/src/ |
| H A D | bidirectional_stream.rs | 35 let expected = match self.encoding { in client_enabled_server_enabled() localVariable 41 assert_eq!(req.headers().get("grpc-encoding").unwrap(), expected); in client_enabled_server_enabled() 88 let expected = match encoding { in client_enabled_server_enabled() localVariable 94 assert_eq!(res.metadata().get("grpc-encoding").unwrap(), expected); in client_enabled_server_enabled()
|
| H A D | client_stream.rs | 32 let expected = match self.encoding { in client_enabled_server_enabled() localVariable 38 assert_eq!(req.headers().get("grpc-encoding").unwrap(), expected); in client_enabled_server_enabled() 160 let expected = match encoding { in client_enabled_server_disabled() localVariable 170 expected in client_enabled_server_disabled() 217 let expected = match encoding { in compressing_response_from_client_stream() localVariable 223 assert_eq!(res.metadata().get("grpc-encoding").unwrap(), expected); in compressing_response_from_client_stream()
|
| H A D | compressing_response.rs | 37 let expected = match self.encoding { in client_enabled_server_enabled() localVariable 49 format!("{},identity", expected) in client_enabled_server_enabled() 87 let expected = match encoding { in client_enabled_server_enabled() localVariable 96 assert_eq!(res.metadata().get("grpc-encoding").unwrap(), expected); in client_enabled_server_enabled() 352 let expected = match encoding { in disabling_compression_on_single_response() localVariable 358 assert_eq!(res.metadata().get("grpc-encoding").unwrap(), expected); in disabling_compression_on_single_response() 410 let expected = match encoding { in disabling_compression_on_response_but_keeping_compression_on_stream() localVariable 416 assert_eq!(res.metadata().get("grpc-encoding").unwrap(), expected); in disabling_compression_on_response_but_keeping_compression_on_stream() 481 let expected = match encoding { in disabling_compression_on_response_from_client_stream() localVariable 487 assert_eq!(res.metadata().get("grpc-encoding").unwrap(), expected); in disabling_compression_on_response_from_client_stream()
|
| H A D | compressing_request.rs | 32 let expected = match self.encoding { in client_enabled_server_enabled() localVariable 38 assert_eq!(req.headers().get("grpc-encoding").unwrap(), expected); in client_enabled_server_enabled() 176 let expected = match encoding { in client_enabled_server_disabled() localVariable 186 expected in client_enabled_server_disabled()
|
| H A D | server_stream.rs | 46 let expected = match encoding { in client_enabled_server_enabled() localVariable 52 assert_eq!(res.metadata().get("grpc-encoding").unwrap(), expected); in client_enabled_server_enabled()
|
| H A D | util.rs | 161 let expected = match self.encoding { in call() localVariable 167 assert_eq!(req.headers().get("grpc-encoding").unwrap(), expected); in call()
|
| /tonic/tonic-types/src/richer_error/std_messages/ |
| H A D | help.rs | 151 let expected = "Help { links: [] }"; in gen_help() localVariable 154 formatted.eq(expected), in gen_help() 184 …let expected = "Any { type_url: \"type.googleapis.com/google.rpc.Help\", value: [10, 46, 10, 18, 1… in gen_help() localVariable 187 formatted.eq(expected), in gen_help()
|
| H A D | bad_request.rs | 155 let expected = "BadRequest { field_violations: [] }"; in gen_bad_request() localVariable 158 formatted.eq(expected), in gen_bad_request() 188 …let expected = "Any { type_url: \"type.googleapis.com/google.rpc.BadRequest\", value: [10, 24, 10,… in gen_bad_request() localVariable 191 formatted.eq(expected), in gen_bad_request()
|
| H A D | quota_failure.rs | 152 let expected = "QuotaFailure { violations: [] }"; in gen_quota_failure() localVariable 155 formatted.eq(expected), in gen_quota_failure() 186 …let expected = "Any { type_url: \"type.googleapis.com/google.rpc.QuotaFailure\", value: [10, 38, 1… in gen_quota_failure() localVariable 189 formatted.eq(expected), in gen_quota_failure()
|
| H A D | prec_failure.rs | 175 let expected = "PreconditionFailure { violations: [] }"; in gen_prec_failure() localVariable 178 formatted.eq(expected), in gen_prec_failure() 209 …let expected = "Any { type_url: \"type.googleapis.com/google.rpc.PreconditionFailure\", value: [10… in gen_prec_failure() localVariable 212 formatted.eq(expected), in gen_prec_failure()
|
| H A D | request_info.rs | 111 let expected = in gen_request_info() localVariable 115 formatted.eq(expected), in gen_request_info()
|
| H A D | loc_message.rs | 112 let expected = in gen_localized_message() localVariable 116 formatted.eq(expected), in gen_localized_message()
|
| H A D | debug_info.rs | 109 let expected = in gen_debug_info() localVariable 113 formatted.eq(expected), in gen_debug_info()
|
| H A D | resource_info.rs | 127 let expected = in gen_resource_info() localVariable 131 formatted.eq(expected), in gen_resource_info()
|
| H A D | error_info.rs | 130 let expected = in gen_error_info() localVariable 134 formatted.eq(expected), in gen_error_info()
|
| H A D | retry_info.rs | 147 let expected = in gen_retry_info() localVariable 151 formatted.eq(expected), in gen_retry_info()
|
| /tonic/tonic-reflection/tests/ |
| H A D | server.rs | 18 let mut expected = Vec::new(); in get_encoded_reflection_service_fd() localVariable 22 .encode(&mut expected) in get_encoded_reflection_service_fd() 24 expected in get_encoded_reflection_service_fd()
|
| /tonic/tests/web/tests/ |
| H A D | grpc_web.rs | 36 let expected = Output { in binary_request() localVariable 41 assert_eq!(message, expected); in binary_request() 59 let expected = Output { in text_request() localVariable 64 assert_eq!(message, expected); in text_request()
|
| /tonic/.github/ISSUE_TEMPLATE/ |
| H A D | bug_report.md | 3 about: If something isn't working as expected . 55 I expected to see this happen: <explanation>
|
| /tonic/tonic-health/src/ |
| H A D | server.rs | 195 fn assert_serving_status(wire: i32, expected: ServingStatus) { in assert_serving_status() 196 let expected = crate::pb::health_check_response::ServingStatus::from(expected) as i32; in assert_serving_status() localVariable 197 assert_eq!(wire, expected); in assert_serving_status() 200 fn assert_grpc_status(wire: Option<Status>, expected: Code) { in assert_grpc_status() 202 assert_eq!(wire, expected); in assert_grpc_status()
|
| /tonic/tonic-web/src/ |
| H A D | call.rs | 640 let mut expected = HeaderMap::new(); in decode_multiple_trailers() localVariable 641 expected.insert(Status::GRPC_STATUS, "0".parse().unwrap()); in decode_multiple_trailers() 642 expected.insert(Status::GRPC_MESSAGE, "".parse().unwrap()); in decode_multiple_trailers() 643 expected.insert("a", "1".parse().unwrap()); in decode_multiple_trailers() 644 expected.insert("b", "2".parse().unwrap()); in decode_multiple_trailers() 646 assert_eq!(trailers, expected); in decode_multiple_trailers() 657 let mut expected = HeaderMap::new(); in decode_trailers_with_space_after_colon() localVariable 658 expected.insert(Status::GRPC_STATUS, "0".parse().unwrap()); in decode_trailers_with_space_after_colon() 659 expected.insert(Status::GRPC_MESSAGE, "".parse().unwrap()); in decode_trailers_with_space_after_colon() 661 assert_eq!(trailers, expected); in decode_trailers_with_space_after_colon()
|
| /tonic/tonic/src/service/ |
| H A D | interceptor.rs | 311 let expected = Status::permission_denied(message).into_http::<()>(); in handles_intercepted_status_as_response() localVariable 324 assert_eq!(expected.status(), response.status()); in handles_intercepted_status_as_response() 325 assert_eq!(expected.version(), response.version()); in handles_intercepted_status_as_response() 326 assert_eq!(expected.headers(), response.headers()); in handles_intercepted_status_as_response()
|
| /tonic/tonic/src/transport/service/ |
| H A D | grpc_timeout.rs | 208 #[should_panic(expected = "82f")] 215 #[should_panic(expected = "123456789H")] 222 #[should_panic(expected = "oneH")]
|
| /tonic/tonic/src/codec/ |
| H A D | prost.rs | 212 let expected = Status::out_of_range(format!( in decode_max_message_size_exceeded() localVariable 218 assert_eq!(actual.code(), expected.code()); in decode_max_message_size_exceeded() 219 assert_eq!(actual.message(), expected.message()); in decode_max_message_size_exceeded()
|
| /tonic/interop/proto/grpc/testing/ |
| H A D | messages.proto | 89 // successful when the client expected it. 140 // Configuration for each expected response message.
|