Searched refs:buffer_size (Results 1 – 5 of 5) sorted by relevance
| /tonic/tonic/src/codec/ |
| H A D | mod.rs | 69 buffer_size: usize, field
75 pub fn new(buffer_size: usize, yield_threshold: usize) -> Self { in new()
77 buffer_size, in new()
86 buffer_size: DEFAULT_CODEC_BUFFER_SIZE, in default()
|
| H A D | decode.rs | 124 let buffer_size = decoder.buffer_settings().buffer_size; in new() localVariable
136 buf: BytesMut::with_capacity(buffer_size), in new()
219 buffer_growth_interval: buffer_settings.buffer_size, in decode_chunk()
|
| H A D | encode.rs | 43 let buf = BytesMut::with_capacity(buffer_settings.buffer_size); in new()
53 BytesMut::with_capacity(buffer_settings.buffer_size) in new()
164 buffer_growth_interval: buffer_settings.buffer_size, in encode_item()
|
| /tonic/tonic/src/transport/channel/ |
| H A D | mod.rs | 157 let buffer_size = endpoint.buffer_size.unwrap_or(DEFAULT_BUFFER_SIZE); in new() localVariable
161 let (svc, worker) = Buffer::pair(svc, buffer_size); in new()
178 let buffer_size = endpoint.buffer_size.unwrap_or(DEFAULT_BUFFER_SIZE); in connect() localVariable
184 let (svc, worker) = Buffer::pair(svc, buffer_size); in connect()
190 pub(crate) fn balance<D, E>(discover: D, buffer_size: usize, executor: E) -> Self in balance()
200 let (svc, worker) = Buffer::pair(svc, buffer_size); in balance()
|
| H A D | endpoint.rs | 28 pub(crate) buffer_size: Option<usize>, field
240 pub fn buffer_size(self, sz: impl Into<Option<usize>>) -> Self { in buffer_size() method
242 buffer_size: sz.into(), in buffer_size()
455 buffer_size: None, in from()
|