| /tonic/tonic/ |
| H A D | Cargo.toml | 37 router = ["dep:axum", "dep:tower", "tower?/util"]
41 "dep:hyper-util", "hyper-util?/service", "hyper-util?/server-auto",
45 "dep:tower", "tower?/util", "tower?/limit",
49 "dep:hyper-util", "hyper-util?/client-legacy",
50 "dep:tower", "tower?/balance", "tower?/buffer", "tower?/discover", "tower?/limit", "tower?/util",
67 http-body-util = "0.1"
83 hyper-util = { version = "0.1.4", features = ["tokio"], optional = true }
|
| /tonic/tests/compression/src/ |
| H A D | server_stream.rs | 5 util::parametrized_tests! {
27 util::CountBytesBody { in client_enabled_server_enabled()
71 util::parametrized_tests! {
92 util::CountBytesBody { in client_disabled_server_enabled()
122 util::parametrized_tests! {
144 util::CountBytesBody { in client_enabled_server_disabled()
|
| H A D | compressing_response.rs | 4 util::parametrized_tests! {
70 util::CountBytesBody { in client_enabled_server_enabled()
102 util::parametrized_tests! {
125 util::CountBytesBody { in client_enabled_server_disabled()
166 util::CountBytesBody { in client_enabled_server_disabled_multi_encoding()
193 util::parametrized_tests! {
240 util::CountBytesBody { in client_disabled()
264 util::parametrized_tests! {
308 util::parametrized_tests! {
364 util::parametrized_tests! {
[all …]
|
| H A D | client_stream.rs | 5 util::parametrized_tests! {
78 util::parametrized_tests! {
129 util::parametrized_tests! {
175 util::parametrized_tests! {
197 util::CountBytesBody { in compressing_response_from_client_stream()
|
| H A D | lib.rs | 3 use self::util::*;
4 use crate::util::mock_io_channel;
26 mod util; module
|
| H A D | bidirectional_stream.rs | 5 util::parametrized_tests! {
61 util::CountBytesBody { in client_enabled_server_enabled()
|
| H A D | compressing_request.rs | 5 util::parametrized_tests! {
82 util::parametrized_tests! {
|
| /tonic/tests/web/ |
| H A D | Cargo.toml | 11 http-body-util = "0.1"
13 hyper-util = "0.1"
|
| /tonic/tests/compression/ |
| H A D | Cargo.toml | 11 http-body-util = "0.1"
13 hyper-util = "0.1"
|
| /tonic/examples/ |
| H A D | Cargo.toml | 256 grpc-web = ["dep:tonic-web", "dep:bytes", "dep:http", "dep:hyper", "dep:hyper-util", "dep:tracing-s…
258 uds = ["dep:tokio-stream", "tokio-stream?/net", "dep:tower", "dep:hyper", "dep:hyper-util"]
260 mock = ["dep:tokio-stream", "dep:tower", "dep:hyper-util"]
265 …s-rustls = ["dep:http", "dep:hyper", "dep:hyper-util", "dep:hyper-rustls", "dep:tower", "tower-htt…
268 h2c = ["dep:hyper", "dep:tower", "dep:http", "dep:hyper-util"]
269 cancellation = ["dep:tokio-util"]
286 tokio-util = { version = "0.7.8", optional = true }
297 hyper-util = { version = "0.1.4", optional = true }
|
| /tonic/tonic/src/metadata/ |
| H A D | encoding.rs | 131 let encoded_value: String = crate::util::base64::STANDARD_NO_PAD.encode(value); in from_bytes()
141 if crate::util::base64::STANDARD.decode(value).is_err() { in from_static()
152 crate::util::base64::STANDARD in decode()
159 if let Ok(decoded) = crate::util::base64::STANDARD.decode(a.as_bytes()) { in equals()
|
| /tonic/tonic-web/src/ |
| H A D | lib.rs | 85 pub(crate) mod util { module
|
| H A D | call.rs | 154 crate::util::base64::STANDARD in decode_chunk()
228 res = crate::util::base64::STANDARD.encode(res).into(); in poll_encode()
238 res = crate::util::base64::STANDARD.encode(res).into(); in poll_encode()
|
| /tonic/interop/ |
| H A D | Cargo.toml | 22 http-body-util = "0.1"
|
| /tonic/tonic/src/ |
| H A D | lib.rs | 113 mod util; module
|
| H A D | status.rs | 452 Some(header) => crate::util::base64::STANDARD in from_header_map()
534 let details = crate::util::base64::STANDARD_NO_PAD.encode(&self.details[..]); in add_header()
1005 let b64_details = crate::util::base64::STANDARD_NO_PAD.encode(DETAILS); in details()
|
| /tonic/tests/integration_tests/ |
| H A D | Cargo.toml | 20 hyper-util = "0.1"
|
| /tonic/tests/web/tests/ |
| H A D | grpc_web.rs | 120 "grpc-web-text" => test_web::util::base64::STANDARD in build_request()
142 body = test_web::util::base64::STANDARD in decode_body()
|
| /tonic/tests/web/src/ |
| H A D | lib.rs | 71 pub mod util { module
|
| /tonic/tonic/src/transport/channel/ |
| H A D | mod.rs | 34 util::BoxService,
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | connection.rs | 18 util::BoxService,
|
| /tonic/tonic/src/transport/server/ |
| H A D | mod.rs | 68 layer::util::{Identity, Stack},
71 util::BoxCloneService,
75 type BoxService = tower::util::BoxCloneService<Request<Body>, Response<Body>, crate::BoxError>;
|