Home
last modified time | relevance | path

Searched defs:usize (Results 1 – 21 of 21) sorted by relevance

/tonic/tonic/src/codec/
H A Dbuffer.rs25 fn remaining(&self) -> usize { in remaining()
41 fn advance(&mut self, cnt: usize) { in advance()
68 pub fn reserve(&mut self, additional: usize) { in reserve()
75 fn remaining_mut(&self) -> usize { in remaining_mut()
80 unsafe fn advance_mut(&mut self, cnt: usize) { in advance_mut()
103 fn put_bytes(&mut self, val: u8, cnt: usize) { in put_bytes()
H A Dencode.rs40 max_message_size: Option<usize>, in new()
138 max_message_size: Option<usize>, in encode_item()
183 max_message_size: Option<usize>, in finish_encoding()
238 max_message_size: Option<usize>, in new_client()
263 max_message_size: Option<usize>, in new_server()
H A Ddecode.rs64 max_message_size: Option<usize>, in new_response()
96 max_message_size: Option<usize>, in new_request()
117 max_message_size: Option<usize>, in new()
H A Dcompression.rs216 len: usize, in compress()
266 len: usize, in decompress()
H A Dmod.rs75 pub fn new(buffer_size: usize, yield_threshold: usize) -> Self { in new()
H A Dprost.rs370 pub(super) fn new(b: &[u8], partial_len: usize, count: usize) -> Self { in new()
/tonic/examples/src/streaming/
H A Dclient.rs17 async fn streaming_echo(client: &mut EchoClient<Channel>, num: usize) { in streaming_echo()
34 async fn bidirectional_streaming_echo(client: &mut EchoClient<Channel>, num: usize) { in bidirectional_streaming_echo()
/tonic/tests/integration_tests/tests/
H A Dmax_message_size.rs195 fn assert_server_recv_max_success(size: usize) { in assert_server_recv_max_success()
206 fn assert_server_recv_max_failure(size: usize) { in assert_server_recv_max_failure()
218 fn assert_client_recv_max_success(size: usize) { in assert_client_recv_max_success()
229 fn assert_client_recv_max_failure(size: usize) { in assert_client_recv_max_failure()
/tonic/tests/integration_tests/src/
H A Dlib.rs41 ) -> Poll<std::io::Result<usize>> { in poll_write()
60 ) -> Poll<Result<usize, std::io::Error>> { in poll_write_vectored()
/tonic/tonic/src/transport/channel/service/
H A Dio.rs44 ) -> Poll<io::Result<usize>> { in poll_write()
60 ) -> Poll<Result<usize, io::Error>> { in poll_write_vectored()
/tonic/tonic-reflection/src/server/
H A Dv1alpha.rs129 fn size_hint(&self) -> (usize, Option<usize>) { in size_hint()
H A Dv1.rs129 fn size_hint(&self) -> (usize, Option<usize>) { in size_hint()
/tonic/tonic/src/metadata/
H A Dmap.rs321 pub fn len(&self) -> usize { in len()
347 pub fn keys_len(&self) -> usize { in keys_len()
404 pub fn capacity(&self) -> usize { in capacity()
429 pub fn reserve(&mut self, additional: usize) { in reserve()
1255 fn size_hint(&self) -> (usize, Option<usize>) { in size_hint()
1282 fn size_hint(&self) -> (usize, Option<usize>) { in size_hint()
1298 fn size_hint(&self) -> (usize, Option<usize>) { in size_hint()
1318 fn size_hint(&self) -> (usize, Option<usize>) { in size_hint()
1341 fn size_hint(&self) -> (usize, Option<usize>) { in size_hint()
1362 fn size_hint(&self) -> (usize, Option<usize>) { in size_hint()
[all …]
H A Dvalue.rs415 pub fn len(&self) -> usize { in len()
/tonic/tonic/benches/
H A Ddecode.rs54 fn len(&self) -> usize { in len()
113 fn make_payload(message_length: usize, message_count: usize) -> Bytes { in make_payload()
/tonic/tonic/src/transport/server/service/
H A Dio.rs146 ) -> Poll<io::Result<usize>> { in poll_write()
174 ) -> Poll<Result<usize, io::Error>> { in poll_write_vectored()
/tonic/tonic/src/server/
H A Dgrpc.rs205 max_decoding_message_size: Option<usize>, in apply_max_message_size_config()
206 max_encoding_message_size: Option<usize>, in apply_max_message_size_config()
424 max_message_size: Option<usize>, in map_response()
/tonic/tonic/src/transport/channel/
H A Dmod.rs135 capacity: usize, in balance_channel_with_executor()
190 pub(crate) fn balance<D, E>(discover: D, buffer_size: usize, executor: E) -> Self in balance()
/tonic/tests/compression/src/
H A Dutil.rs77 fn frame_data_length(frame: &http_body::Frame<Bytes>) -> usize { in frame_data_length()
/tonic/tonic/src/transport/service/
H A Dgrpc_timeout.rs250 fn gen_string(g: &mut Gen, min: usize, max: usize) -> String { in gen_string()
/tonic/tonic-web/src/
H A Dcall.rs140 fn max_decodable(&self) -> usize { in max_decodable()