| /tonic/tests/integration_tests/proto/ |
| H A D | test.proto | 19 bytes buf = 1;
22 bytes buf = 1;
|
| /tonic/tonic/src/codec/ |
| H A D | buffer.rs | 1 use bytes::buf::UninitSlice;
2 use bytes::{Buf, BufMut, Bytes, BytesMut};
136 let mut bytes = BytesMut::with_capacity(100); in encode_buf() localVariable
137 let mut buf = EncodeBuf::new(&mut bytes); in encode_buf()
|
| H A D | prost.rs | 157 use bytes::{Buf, BufMut, BytesMut};
351 use bytes::Bytes;
|
| /tonic/tonic/src/ |
| H A D | body.rs | 8 type BoxBody = http_body_util::combinators::UnsyncBoxBody<bytes::Bytes, crate::Status>;
35 B: http_body::Body<Data = bytes::Bytes> + Send + 'static, in new()
68 type Data = bytes::Bytes;
|
| H A D | codegen.rs | 15 pub use bytes::Bytes;
|
| H A D | status.rs | 4 use bytes::Bytes;
789 pub fn from_bytes(bytes: &[u8]) -> Code { in from_bytes()
790 match bytes.len() { in from_bytes()
791 1 => match bytes[0] { in from_bytes()
804 2 => match (bytes[0], bytes[1]) { in from_bytes()
|
| /tonic/tonic-web/ |
| H A D | Cargo.toml | 20 bytes = "1"
42 "bytes::*",
|
| /tonic/tests/use_arc_self/proto/ |
| H A D | test.proto | 11 bytes data = 1;
|
| /tonic/tests/web/ |
| H A D | Cargo.toml | 9 bytes = "1.0"
|
| /tonic/tests/web/tests/ |
| H A D | grpc_web.rs | 4 use bytes::{Buf, BufMut, Bytes, BytesMut};
118 let bytes = match content_type { in build_request() localVariable
133 Full::new(bytes).map_err(|err| Status::internal(err.to_string())), in build_request()
|
| /tonic/tests/compression/ |
| H A D | Cargo.toml | 8 bytes = "1"
|
| /tonic/tests/compression/proto/ |
| H A D | test.proto | 18 bytes data = 1;
|
| /tonic/tests/integration_tests/ |
| H A D | Cargo.toml | 10 bytes = "1.0"
|
| /tonic/tonic-build/src/ |
| H A D | prost.rs | 32 bytes: None, in configure()
301 pub(crate) bytes: Option<Vec<String>>, field
451 pub fn bytes<I, S>(mut self, paths: I) -> Self in bytes() method
456 self.bytes = Some( in bytes()
683 if let Some(ref paths) = self.bytes { in setup_config()
684 config.bytes(paths); in setup_config()
|
| /tonic/tonic/benches/ |
| H A D | decode.rs | 4 use bytes::{Buf, BufMut, Bytes, BytesMut};
22 b.bytes = body.len() as u64;
|
| /tonic/tonic-health/ |
| H A D | Cargo.toml | 36 "bytes::*",
|
| /tonic/examples/ |
| H A D | README.md | 148 * [bytes](https://crates.io/crates/bytes)
|
| H A D | Cargo.toml | 256 grpc-web = ["dep:tonic-web", "dep:bytes", "dep:http", "dep:hyper", "dep:hyper-util", "dep:tracing-s…
262 json-codec = ["dep:serde", "dep:serde_json", "dep:bytes"]
299 bytes = { version = "1", optional = true }
|
| /tonic/tonic/src/metadata/ |
| H A D | encoding.rs | 2 use bytes::Bytes;
17 use bytes::Bytes;
|
| /tonic/tonic-reflection/ |
| H A D | Cargo.toml | 48 "bytes::*",
|
| /tonic/examples/src/json-codec/ |
| H A D | common.rs | 5 use bytes::{Buf, BufMut};
|
| /tonic/tonic/src/transport/service/ |
| H A D | grpc_timeout.rs | 251 let bytes: Vec<_> = (min..max) in gen_string() localVariable
260 String::from_utf8(bytes).unwrap() in gen_string()
|
| /tonic/tonic/ |
| H A D | Cargo.toml | 62 bytes = "1.0"
120 "bytes::*",
|
| /tonic/tonic/benches-disabled/ |
| H A D | README.md | 12 2) The `thrpt` value generated by Criterion is simply a measure of bytes consumed by the target fun…
|
| /tonic/tonic-web/src/ |
| H A D | service.rs | 49 B: http_body::Body<Data = bytes::Bytes> + Send + 'static,
208 B: http_body::Body<Data = bytes::Bytes> + Send + 'static, in coerce_request()
229 B: http_body::Body<Data = bytes::Bytes> + Send + 'static, in coerce_response()
|