Searched refs:BytesMut (Results 1 – 10 of 10) sorted by relevance
| /tonic/tonic/src/codec/ |
| H A D | buffer.rs | 2 use bytes::{Buf, BufMut, Bytes, BytesMut};
7 buf: &'a mut BytesMut,
14 buf: &'a mut BytesMut,
18 pub(crate) fn new(buf: &'a mut BytesMut, len: usize) -> Self { in new() argument
56 pub(crate) fn new(buf: &'a mut BytesMut) -> Self { in new()
114 let mut payload = BytesMut::with_capacity(100); in decode_buf()
136 let mut bytes = BytesMut::with_capacity(100); in encode_buf()
|
| H A D | encode.rs | 6 use bytes::{BufMut, Bytes, BytesMut};
29 buf: BytesMut,
30 uncompression_buf: BytesMut,
43 let buf = BytesMut::with_capacity(buffer_settings.buffer_size); in new()
53 BytesMut::with_capacity(buffer_settings.buffer_size) in new()
55 BytesMut::new() in new()
135 buf: &mut BytesMut, in encode_item() argument
136 uncompression_buf: &mut BytesMut, in encode_item() argument
|
| H A D | compression.rs | 2 use bytes::{Buf, BufMut, BytesMut};
49 let mut value = BytesMut::new(); in into_accept_encoding_header_value()
214 decompressed_buf: &mut BytesMut, in compress() argument
215 out_buf: &mut BytesMut, in compress() argument
264 compressed_buf: &mut BytesMut, in decompress() argument
265 out_buf: &mut BytesMut, in decompress() argument
|
| H A D | decode.rs | 4 use bytes::{Buf, BufMut, BytesMut};
30 buf: BytesMut,
32 decompress_buf: BytesMut,
136 buf: BytesMut::with_capacity(buffer_size), in new()
138 decompress_buf: BytesMut::new(), in new()
|
| H A D | prost.rs | 157 use bytes::{Buf, BufMut, BytesMut};
172 let mut buf = BytesMut::new(); in decode()
198 let mut buf = BytesMut::new(); in decode_max_message_size_exceeded()
|
| /tonic/tonic-web/src/ |
| H A D | call.rs | 6 use bytes::{Buf, BufMut, Bytes, BytesMut};
65 buf: BytesMut,
66 decoded: BytesMut,
107 buf: BytesMut::with_capacity(match (direction, encoding) { in new_client()
111 decoded: BytesMut::with_capacity(match direction { in new_client()
125 buf: BytesMut::with_capacity(match (direction, encoding) { in new()
129 decoded: BytesMut::with_capacity(0), in new()
451 let mut frame = BytesMut::with_capacity(len + FRAME_HEADER_SIZE); in make_trailers_frame()
|
| /tonic/tonic/benches/ |
| H A D | decode.rs | 4 use bytes::{Buf, BufMut, Bytes, BytesMut};
114 let mut buf = BytesMut::new(); in make_payload()
|
| /tonic/tests/web/tests/ |
| H A D | grpc_web.rs | 4 use bytes::{Buf, BufMut, Bytes, BytesMut};
93 let mut buf = BytesMut::with_capacity(1024); in encode_body()
|
| /tonic/tonic-types/src/richer_error/ |
| H A D | mod.rs | 2 bytes::{Bytes, BytesMut},
44 let mut buf = BytesMut::with_capacity(status.encoded_len()); in gen_details_bytes()
|
| /tonic/ |
| H A D | CHANGELOG.md | 601 * **codec:** Add new `Decoder/Encoder` traits and use `EncodeBuf/DecodeBuf` over `BytesMut` directl…
|