Home
last modified time | relevance | path

Searched refs:None (Results 1 – 25 of 51) sorted by relevance

123

/tonic/tonic/src/codec/
H A Ddecode.rs87 Self::new(decoder, body, Direction::EmptyResponse, None, None) in new_empty()
157 0 => None, in decode_chunk()
244 Ok(None) in decode_chunk()
260 None => { in poll_frame()
266 Ok(None) in poll_frame()
281 Ok(None) in poll_frame()
333 None => Ok(None), in message()
369 Ok(None) in trailers()
379 None => Ok(None), in decode_chunk()
381 None => Ok(None), in decode_chunk()
[all …]
H A Dcompression.rs30 None => { in enable()
56 return None; in into_accept_encoding_header_value()
113 return None; in from_accept_encoding_header()
126 _ => None, in from_accept_encoding_header()
136 return Ok(None); in from_encoding_header()
152 b"identity" => Ok(None), in from_encoding_header()
332 inner: [Some(CompressionEncoding::Gzip), None, None], in convert_gzip_into_header_value()
338 inner: [None, None, Some(CompressionEncoding::Gzip)], in convert_gzip_into_header_value()
350 inner: [Some(CompressionEncoding::Zstd), None, None], in convert_zstd_into_header_value()
356 inner: [None, None, Some(CompressionEncoding::Zstd)], in convert_zstd_into_header_value()
H A Dencode.rs47 None in new()
65 error: None, in new()
98 Poll::Ready(None) if buf.is_empty() => { in poll_next()
99 return Poll::Ready(None); in poll_next()
101 Poll::Pending | Poll::Ready(None) => { in poll_next()
249 error: None, in new_client()
274 error: None, in new_server()
285 Role::Client => None, in trailers()
288 return None; in trailers()
329 None => self_proj in poll_frame()
H A Dprost.rs182 let mut stream = Streaming::new_request(decoder, body, None, None); in decode()
208 let mut stream = Streaming::new_request(decoder, body, None, Some(MAX_MESSAGE_SIZE)); in decode_max_message_size_exceeded()
234 None, in encode()
236 None, in encode()
256 None, in encode_max_message_size_exceeded()
293 None, in encode_too_big()
406 Poll::Ready(None) in poll_frame()
/tonic/tonic/src/transport/channel/
H A Dendpoint.rs448 origin: None, in from()
449 user_agent: None, in from()
450 concurrency_limit: None, in from()
451 rate_limit: None, in from()
452 timeout: None, in from()
454 tls: None, in from()
455 buffer_size: None, in from()
458 tcp_keepalive: None, in from()
464 connect_timeout: None, in from()
465 http2_adaptive_window: None, in from()
[all …]
/tonic/tonic-types/src/richer_error/std_messages/
H A Dretry_info.rs42 None => None, in new()
90 None => None, in from()
111 None => None, in from()
/tonic/tonic-web/src/
H A Dcall.rs56 None, enumerator
80 encoding: Encoding::None, in default()
118 trailers: None, in new_client()
133 trailers: None, in new()
147 return Ok(None); in decode_chunk()
195 None => { in poll_decode()
207 Encoding::None => self in poll_decode()
245 None => Poll::Ready(None), in poll_encode()
316 0 => None, in poll_frame()
370 _ => Encoding::None, in from_header()
[all …]
/tonic/tonic/src/transport/service/
H A Dgrpc_timeout.rs44 None in call()
49 (None, None) => None, in call()
50 (Some(dur), None) => Some(dur), in call()
51 (None, Some(dur)) => Some(dur), in call()
107 return Ok(None); in try_parse_grpc_timeout()
203 let parsed_duration = setup_map_try_parse(None).unwrap(); in test_header_not_present()
/tonic/tonic/src/service/
H A Drecover_error.rs129 Self { inner: None } in empty()
146 None => Poll::Ready(None), in poll_frame()
153 None => true, in is_end_stream()
160 None => http_body::SizeHint::with_exact(0), in size_hint()
/tonic/tonic/src/transport/server/
H A Dmod.rs114 trace_interceptor: None, in default()
115 concurrency_limit: None, in default()
116 timeout: None, in default()
118 tls: None, in default()
122 tcp_keepalive: None, in default()
126 http2_adaptive_window: None, in default()
129 max_frame_size: None, in default()
132 max_connection_age: None, in default()
725 None => { in serve_internal()
821 None => pending().await, in sleep_or_pending()
[all …]
H A Dio_stream.rs64 None => Poll::Ready(None), in poll_next_without_tls()
119 SelectOutput::Done => Poll::Ready(None), in poll_next()
155 Ok(None) => SelectOutput::Done, in select()
H A Dincoming.rs79 nodelay: None, in from()
80 keepalive: None, in from()
/tonic/interop/src/
H A Dlib.rs44 None => 0, in response_length()
95 why: None, in fmt()
118 why: None,
/tonic/tonic-types/src/richer_error/
H A Dmod.rs861 None in get_details_retry_info()
873 None in get_details_debug_info()
885 None in get_details_quota_failure()
897 None in get_details_error_info()
909 None in get_details_precondition_failure()
921 None in get_details_bad_request()
933 None in get_details_request_info()
945 None in get_details_resource_info()
957 None in get_details_help()
969 None in get_details_localized_message()
/tonic/tonic/src/transport/channel/service/
H A Dtls.rs52 None => with_provider(Arc::new(crypto::ring::default_provider())), in new()
54 None => with_provider(Arc::new(crypto::aws_lc_rs::default_provider())), in new()
89 None => builder.with_no_client_auth(), in new()
H A Ddiscover.rs36 Poll::Pending | Poll::Ready(None) => Poll::Pending, in poll_next()
H A Duser_agent.rs58 UserAgent::new(Svc, None).user_agent, in sets_default_if_no_custom_user_agent()
/tonic/tonic/benches/
H A Ddecode.rs27 let mut stream = Streaming::new_request(decoder, body.clone(), None, None);
71 Poll::Ready(None) in poll_frame()
/tonic/tonic-reflection/src/server/
H A Dmod.rs141 None => { in new()
254 None => Err(Status::not_found(format!("symbol '{}' not found", symbol))), in symbol_by_name()
268 None => Err(Status::not_found(format!("file '{}' not found", filename))), in file_by_filename()
287 None => Err(Error::InvalidFileDescriptorSet(format!( in extract_name()
/tonic/tonic-types/src/richer_error/error_details/
H A Dmod.rs517 None => { in add_quota_failure_violation()
631 None => { in add_precondition_failure_violation()
711 None => { in add_bad_request_violation()
832 None => { in add_help_link()
/tonic/tonic/src/metadata/
H A Dmap.rs1380 None => None, in next()
1401 None => None, in next_back()
2243 return None; in get()
2254 return None; in get_mut()
2265 return None; in get_all()
2290 return None; in remove()
2305 return None; in get()
2316 return None; in get_mut()
2327 return None; in get_all()
2351 return None; in remove()
[all …]
/tonic/examples/src/autoreload/
H A Dserver.rs46 None => { in main()
/tonic/tonic/src/
H A Dstatus.rs168 source: None, in new()
429 None in from_hyper_error()
448 None => Ok(String::new()), in from_header_map()
456 None => Bytes::new(), in from_header_map()
481 source: None, in from_header_map()
567 source: None, in with_details_and_metadata()
607 source: None, in find_status_in_source_chain()
635 None in find_status_in_source_chain()
764 http::StatusCode::OK => return Err(None), in infer_grpc_status()
/tonic/tonic-build/src/
H A Dprost.rs22 file_descriptor_set_path: None, in configure()
24 out_dir: None, in configure()
31 btree_map: None, in configure()
32 bytes: None, in configure()
39 include_file: None, in configure()
/tonic/tests/integration_tests/tests/
H A Duser_agent.rs18 None => Err(Status::internal("user-agent header is missing")), in writes_user_agent_header()

123