Home
last modified time | relevance | path

Searched refs:Error (Results 1 – 25 of 129) sorted by relevance

123456

/tonic/tonic/src/client/
H A Dservice.rs17 type Error: Into<crate::BoxError>; typedef
19 type Future: Future<Output = Result<http::Response<Self::ResponseBody>, Self::Error>>;
24 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>; in poll_ready() argument
35 T::Error: Into<crate::BoxError>,
37 <ResBody as Body>::Error: Into<crate::BoxError>,
40 type Error = T::Error; typedef
43 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() argument
/tonic/tonic/src/transport/
H A Derror.rs1 use std::{error::Error as StdError, fmt};
6 pub struct Error { struct
24 impl Error { impl
37 Error::new(Kind::Transport).with(source) in from_source()
42 Error::new(Kind::InvalidUri) in new_invalid_uri()
47 Error::new(Kind::InvalidUserAgent) in new_invalid_user_agent()
61 impl fmt::Debug for Error { implementation
75 impl fmt::Display for Error { implementation
81 impl StdError for Error { implementation
/tonic/tonic/src/codec/
H A Dmod.rs111 type Encoder: Encoder<Item = Self::Encode, Error = Status> + Send + 'static;
113 type Decoder: Decoder<Item = Self::Decode, Error = Status> + Send + 'static;
129 type Error: From<io::Error>; typedef
132 fn encode(&mut self, item: Self::Item, dst: &mut EncodeBuf<'_>) -> Result<(), Self::Error>; in encode() argument
146 type Error: From<io::Error>; typedef
153 fn decode(&mut self, src: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error>; in decode() argument
H A Ddecode.rs22 decoder: Box<dyn Decoder<Item = T, Error = Status> + Send + 'static>,
46 Error(Option<Status>), enumerator
68 B::Error: Into<crate::BoxError>, in new_response() argument
69 D: Decoder<Item = T, Error = Status> + Send + 'static, in new_response()
84 B::Error: Into<crate::BoxError>, in new_empty() argument
85 D: Decoder<Item = T, Error = Status> + Send + 'static, in new_empty()
100 B::Error: Into<crate::BoxError>, in new_request() argument
101 D: Decoder<Item = T, Error = Status> + Send + 'static, in new_request()
121 B::Error: Into<crate::BoxError>, in new() argument
122 D: Decoder<Item = T, Error = Status> + Send + 'static, in new()
[all …]
/tonic/tonic/src/transport/channel/
H A Dendpoint.rs7 use crate::transport::Error;
47 pub fn new<D>(dst: D) -> Result<Self, Error> in new()
50 D::Error: Into<crate::BoxError>, in new()
108 .map_err(|_| Error::new_invalid_user_agent()) in user_agent()
254 .map_err(Error::from_source)?, in tls_config()
374 crate::BoxError: From<C::Error> + Send, in connect_with_connector()
399 crate::BoxError: From<C::Error> + Send, in connect_with_connector_lazy()
473 type Error = Error; typedef
481 type Error = Error; typedef
489 type Error = Error; typedef
[all …]
H A Dmod.rs153 C::Error: Into<crate::BoxError> + Send, in new()
171 pub async fn connect<C>(connector: C, endpoint: Endpoint) -> Result<Self, super::Error> in connect()
174 C::Error: Into<crate::BoxError> + Send, in connect()
183 .map_err(super::Error::from_source)?; in connect()
193 D::Error: Into<crate::BoxError>, in balance()
209 type Error = super::Error; typedef
212 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() argument
213 Service::poll_ready(&mut self.svc, cx).map_err(super::Error::from_source) in poll_ready()
224 type Output = Result<Response<Body>, super::Error>;
229 .map_err(super::Error::from_source) in poll()
/tonic/tonic-reflection/src/server/
H A Dmod.rs127 ) -> Result<Self, Error> { in new() argument
164 ) -> Result<(), Error> { in process_file() argument
196 ) -> Result<(), Error> { in process_message() argument
225 ) -> Result<(), Error> { in process_enum() argument
242 ) -> Result<(), Error> { in process_field() argument
285 ) -> Result<String, Error> { in extract_name() argument
303 pub enum Error { enum
310 impl From<DecodeError> for Error { implementation
312 Error::DecodeError(e) in from()
316 impl std::error::Error for Error {} implementation
[all …]
/tonic/tonic/src/transport/server/
H A Dmod.rs42 use crate::transport::Error;
566 ) -> Result<(), super::Error> in serve_with_shutdown()
587 ) -> Result<(), super::Error> in serve_with_incoming()
610 ) -> Result<(), super::Error> in serve_with_incoming_shutdown()
632 ) -> Result<(), super::Error> in serve_internal()
776 B::Error: Into<Box<dyn std::error::Error + Send + Sync>> + Send + Sync, in serve_connection()
780 S::Error: Into<Box<dyn std::error::Error + Send + Sync>> + Send, in serve_connection()
900 ) -> Result<(), super::Error> in serve_with_shutdown()
924 ) -> Result<(), super::Error> in serve_with_incoming()
955 ) -> Result<(), super::Error> in serve_with_incoming_shutdown()
[all …]
/tonic/tonic/src/transport/channel/service/
H A Dreconnect.rs15 M::Error: Into<crate::BoxError>,
35 M::Error: Into<crate::BoxError>,
54 crate::BoxError: From<M::Error> + From<S::Error>,
56 <M as tower_service::Service<Target>>::Error: Into<crate::BoxError>,
59 type Error = crate::BoxError; typedef
62 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() argument
162 <M as tower_service::Service<Target>>::Error: Into<crate::BoxError>,
185 Error(Option<crate::BoxError>), enumerator
197 inner: Inner::Error(Some(error)), in error()
214 InnerProj::Error(e) => { in poll()
H A Dconnection.rs31 C::Error: Into<crate::BoxError> + Send, in new()
86 C::Error: Into<crate::BoxError> + Send, in connect()
96 C::Error: Into<crate::BoxError> + Send, in lazy()
106 type Error = crate::BoxError; typedef
107 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>;
109 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() argument
144 type Error = crate::BoxError; typedef
145 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>;
177 C::Error: Into<crate::BoxError> + Send,
182 type Error = crate::BoxError; typedef
[all …]
H A Dadd_origin.rs33 T::Error: Into<crate::BoxError>,
36 type Error = crate::BoxError; typedef
37 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>;
39 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() argument
45 let err = crate::transport::Error::new_invalid_uri(); in call()
H A Dconnector.rs38 crate::BoxError: From<C::Error> + Send + 'static,
41 type Error = ConnectError; typedef
42 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>;
44 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() argument
94 impl std::error::Error for HttpsUriWithoutTlsSupport {}
/tonic/tonic/benches-disabled/benchmarks/compiled_protos/
H A Dhelloworld.rs23 pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error> in connect()
26 D::Error: Into<StdError>, in connect()
36 T::Error: Into<StdError>,
37 <T::ResponseBody as Body>::Error: Into<StdError> + Send,
114 type Error = Never; typedef
115 type Future = Ready<Result<Self::Response, Self::Error>>;
116 fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() argument
125 type Error = Never; typedef
126 type Future = BoxFuture<Self::Response, Self::Error>;
127 fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() argument
/tonic/tonic/src/
H A Dstatus.rs10 use std::{borrow::Cow, error::Error, fmt, sync::Arc};
390 fn to_h2_error(&self) -> h2::Error { in to_h2_error() argument
663 fn invalid_header_value_byte<Error: fmt::Display>(err: Error) -> Status { in invalid_header_value_byte()
672 impl From<h2::Error> for Status {
673 fn from(err: h2::Error) -> Self { in from()
679 impl From<Status> for h2::Error { implementation
685 impl From<std::io::Error> for Status {
725 impl Error for Status {
893 impl std::error::Error for Nested {
929 use std::error::Error as _; in from_error_h2()
[all …]
/tonic/examples/src/tower/
H A Dclient.rs13 async fn main() -> Result<(), Box<dyn std::error::Error>> { in main()
62 type Error = Box<dyn std::error::Error + Send + Sync>; typedef
64 type Future = Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send>>;
66 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() argument
H A Dserver.rs34 async fn main() -> Result<(), Box<dyn std::error::Error>> { in main()
90 type Error = S::Error; typedef
91 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>;
93 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() argument
/tonic/examples/src/h2c/
H A Dserver.rs35 async fn main() -> Result<(), Box<dyn std::error::Error>> { in main()
80 type BoxError = Box<dyn std::error::Error + Send + Sync>;
86 S::Error: Into<BoxError> + 'static,
89 type Error = hyper::Error; typedef
91 Pin<Box<dyn std::future::Future<Output = Result<Self::Response, Self::Error>> + Send>>;
96 ) -> std::task::Poll<Result<(), Self::Error>> { in poll_ready() argument
H A Dclient.rs12 async fn main() -> Result<(), Box<dyn std::error::Error>> { in main()
51 type Error = hyper::Error; typedef
53 Pin<Box<dyn std::future::Future<Output = Result<Self::Response, Self::Error>> + Send>>;
55 fn poll_ready(&mut self, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() argument
/tonic/tests/integration_tests/tests/
H A Dorigin.rs88 T::Error: Into<Box<dyn std::error::Error + Send + Sync>>,
91 type Error = Box<dyn std::error::Error + Send + Sync>; typedef
92 type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>;
94 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() argument
/tonic/examples/src/streaming/
H A Dserver.rs5 use std::{error::Error, io::ErrorKind, net::ToSocketAddrs, pin::Pin, time::Duration};
15 fn match_for_io_error(err_status: &Status) -> Option<&std::io::Error> { in match_for_io_error() argument
16 let mut err: &(dyn Error + 'static) = err_status; in match_for_io_error()
19 if let Some(io_err) = err.downcast_ref::<std::io::Error>() { in match_for_io_error()
25 if let Some(h2_err) = err.downcast_ref::<h2::Error>() { in match_for_io_error()
142 async fn main() -> Result<(), Box<dyn std::error::Error>> { in main()
/tonic/examples/src/json-codec/
H A Dcommon.rs28 type Error = Status; typedef
30 fn encode(&mut self, item: Self::Item, buf: &mut EncodeBuf<'_>) -> Result<(), Self::Error> { in encode() argument
40 type Error = Status; typedef
42 fn decode(&mut self, buf: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error> { in decode() argument
/tonic/examples/src/routeguide/
H A Dclient.rs1 use std::error::Error;
17 async fn print_features(client: &mut RouteGuideClient<Channel>) -> Result<(), Box<dyn Error>> { in print_features() argument
41 async fn run_record_route(client: &mut RouteGuideClient<Channel>) -> Result<(), Box<dyn Error>> { in run_record_route() argument
61 async fn run_route_chat(client: &mut RouteGuideClient<Channel>) -> Result<(), Box<dyn Error>> { in run_route_chat() argument
93 async fn main() -> Result<(), Box<dyn std::error::Error>> { in main()
/tonic/tonic/src/service/
H A Drecover_error.rs55 S::Error: Into<crate::BoxError>,
58 type Error = crate::BoxError; typedef
61 fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() argument
138 type Error = B::Error; typedef
143 ) -> Poll<Option<Result<http_body::Frame<Self::Data>, Self::Error>>> { in poll_frame() argument
H A Drouter.rs28 S: Service<Request<Body>, Error = Infallible> in add_service() argument
60 S: Service<Request<Body>, Error = Infallible> in new() argument
80 S: Service<Request<Body>, Error = Infallible> in add_service() argument
146 B::Error: Into<crate::BoxError>,
149 type Error = crate::BoxError; typedef
153 fn poll_ready(&mut self, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { in poll_ready() argument
/tonic/tonic/benches/
H A Ddecode.rs7 fmt::{Error, Formatter},
61 type Error = Status; typedef
66 ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>> { in poll_frame() argument
85 fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error> { in fmt() argument
104 type Error = Status; typedef
106 fn decode(&mut self, buf: &mut DecodeBuf<'_>) -> Result<Option<Self::Item>, Self::Error> { in decode() argument

123456