Home
last modified time | relevance | path

Searched refs:source (Results 1 – 9 of 9) sorted by relevance

/tonic/tonic/src/transport/
H A Derror.rs12 source: Option<Source>, field
27 inner: ErrorImpl { kind, source: None }, in new()
31 pub(crate) fn with(mut self, source: impl Into<Source>) -> Self { in with()
32 self.inner.source = Some(source.into()); in with()
36 pub(crate) fn from_source(source: impl Into<crate::BoxError>) -> Self { in from_source()
37 Error::new(Kind::Transport).with(source) in from_source()
67 if let Some(source) = &self.inner.source { in fmt()
68 f.field(source); in fmt()
82 fn source(&self) -> Option<&(dyn StdError + 'static)> { in source() method
84 .source in source()
[all …]
/tonic/tonic/src/codec/
H A Dencode.rs25 source: Fuse<U>, field
37 source: U, in new()
59 source: source.fuse(), in new()
79 mut source, in poll_next()
94 match source.as_mut().poll_next(cx) { in poll_next()
236 source: U, in new_client()
243 source, in new_client()
260 source: U, in new_server()
268 source, in new_server()
H A Dprost.rs229 let source = tokio_stream::iter(messages); in encode() localVariable
233 source, in encode()
251 let source = tokio_stream::iter(messages); in encode_max_message_size_exceeded() localVariable
255 source, in encode_max_message_size_exceeded()
288 let source = tokio_stream::iter(messages); in encode_too_big() localVariable
292 source, in encode_too_big()
/tonic/tonic/src/
H A Dstatus.rs168 source: None, in new()
321 status.source = Some(err.into()); in from_error()
481 source: None, in from_header_map()
567 source: None, in with_details_and_metadata()
573 self.source = Some(source); in set_source()
596 let mut source = Some(err); in find_status_in_source_chain() localVariable
598 while let Some(err) = source { in find_status_in_source_chain()
607 source: None, in find_status_in_source_chain()
632 source = err.source(); in find_status_in_source_chain()
936 let source = found in from_error_h2() localVariable
[all …]
/tonic/tests/integration_tests/tests/
H A Dstatus.rs208 let source = error.source().unwrap(); in status_from_server_stream_with_source() localVariable
209 source.downcast_ref::<tonic::transport::Error>().unwrap(); in status_from_server_stream_with_source()
/tonic/examples/src/streaming/
H A Dserver.rs31 err = err.source()?; in match_for_io_error()
/tonic/
H A DREADME.md3 A rust implementation of [gRPC], a high performance, open source, general
H A DCHANGELOG.md332 * **tonic:** Status code to set correct source on unkown error ([#799](https://github.com/hyperium/…
389 * **tonic:** add `h2::Error` as a `source` for `Status` ([#612](https://github.com/hyperium/tonic/i…
/tonic/examples/proto/googleapis/google/pubsub/v1/
H A Dpubsub.proto861 // An authentication method used by push endpoints to verify the source of
1218 // backlog in the source subscription. Specifically, the lifetime of the