Home
last modified time | relevance | path

Searched refs:BoxError (Results 1 – 25 of 28) sorted by relevance

12

/tonic/tonic/src/transport/server/
H A Dio_stream.rs23 struct State<IO>(TlsAcceptor, JoinSet<Result<ServerIo<IO>, crate::BoxError>>);
51 ) -> Poll<Option<Result<ServerIo<IO>, crate::BoxError>>> in poll_next_without_tls()
53 IE: Into<crate::BoxError>, in poll_next_without_tls() argument
73 IE: Into<crate::BoxError>,
75 type Item = Result<ServerIo<IO>, crate::BoxError>;
124 fn handle_tcp_accept_error(e: impl Into<crate::BoxError>) -> ControlFlow<crate::BoxError> { in handle_tcp_accept_error() argument
147 tasks: &mut JoinSet<Result<ServerIo<IO>, crate::BoxError>>, in select() argument
150 IE: Into<crate::BoxError>, in select() argument
180 TcpErr(crate::BoxError),
181 TlsErr(crate::BoxError),
H A Dmod.rs596 IE: Into<crate::BoxError>, in serve_with_incoming() argument
619 IE: Into<crate::BoxError>, in serve_with_incoming_shutdown() argument
641 IE: Into<crate::BoxError>, in serve_internal() argument
883 Into<crate::BoxError> + Send, in serve()
906 Into<crate::BoxError> + Send, in serve_with_shutdown()
928 IE: Into<crate::BoxError>, in serve_with_incoming() argument
959 IE: Into<crate::BoxError>, in serve_with_incoming_shutdown() argument
990 S::Error: Into<crate::BoxError>,
995 type Error = crate::BoxError;
1034 E: Into<crate::BoxError>,
[all …]
H A Dtls.rs76 pub(crate) fn tls_acceptor(&self) -> Result<TlsAcceptor, crate::BoxError> { in tls_acceptor() argument
/tonic/tonic/src/transport/channel/service/
H A Dreconnect.rs15 M::Error: Into<crate::BoxError>,
20 error: Option<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;
162 <M as tower_service::Service<Target>>::Error: Into<crate::BoxError>,
185 Error(Option<crate::BoxError>),
195 pub(crate) fn error(error: crate::BoxError) -> Self { in error()
205 E: Into<crate::BoxError>,
[all …]
H A Dconnection.rs24 inner: BoxService<Request<Body>, Response<Body>, crate::BoxError>,
31 C::Error: Into<crate::BoxError> + Send, in new()
83 ) -> Result<Self, crate::BoxError> in connect()
86 C::Error: Into<crate::BoxError> + Send, in connect()
96 C::Error: Into<crate::BoxError> + Send, in lazy()
106 type Error = crate::BoxError;
144 type Error = crate::BoxError;
177 C::Error: Into<crate::BoxError> + Send,
182 type Error = crate::BoxError;
H A Dadd_origin.rs33 T::Error: Into<crate::BoxError>,
36 type Error = crate::BoxError;
H A Dconnector.rs38 crate::BoxError: From<C::Error> + Send + 'static,
72 Ok::<_, crate::BoxError>(BoxedIo::new(io)) in call()
H A Dtls.rs39 ) -> Result<Self, crate::BoxError> { in new() argument
104 pub(crate) async fn connect<I>(&self, io: I) -> Result<BoxedIo, crate::BoxError> in connect()
H A Ddiscover.rs32 type Item = Result<TowerChange<K, Connection>, crate::BoxError>;
/tonic/tonic/src/client/
H A Dservice.rs17 type Error: Into<crate::BoxError>;
35 T::Error: Into<crate::BoxError>,
37 <ResBody as Body>::Error: Into<crate::BoxError>,
H A Dgrpc.rs216 <T::ResponseBody as HttpBody>::Error: Into<crate::BoxError>, in unary() argument
235 <T::ResponseBody as HttpBody>::Error: Into<crate::BoxError>, in client_streaming() argument
272 <T::ResponseBody as HttpBody>::Error: Into<crate::BoxError>, in server_streaming() argument
291 <T::ResponseBody as HttpBody>::Error: Into<crate::BoxError>, in streaming() argument
331 <T::ResponseBody as HttpBody>::Error: Into<crate::BoxError>, in create_response() argument
/tonic/tests/integration_tests/tests/
H A Dcomplex_tower_middleware.rs11 use tower::{layer::Layer, BoxError, Service};
61 type Error = BoxError;
82 type Output = Result<http::Response<MyBody<B>>, BoxError>;
98 type Error = BoxError;
/tonic/tonic/src/service/
H A Drecover_error.rs55 S::Error: Into<crate::BoxError>,
58 type Error = crate::BoxError;
88 E: Into<crate::BoxError>,
90 type Output = Result<Response<ResponseBody<ResBody>>, crate::BoxError>;
H A Drouter.rs146 B::Error: Into<crate::BoxError>,
149 type Error = crate::BoxError;
171 type Output = Result<Response<Body>, crate::BoxError>;
/tonic/tonic/src/transport/channel/
H A Dmod.rs67 svc: Buffer<Request<Body>, BoxFuture<'static, Result<Response<Body>, crate::BoxError>>>,
74 inner: BufferResponseFuture<BoxFuture<'static, Result<Response<Body>, crate::BoxError>>>,
153 C::Error: Into<crate::BoxError> + Send, in new()
174 C::Error: Into<crate::BoxError> + Send, in connect()
193 D::Error: Into<crate::BoxError>, in balance() argument
H A Dendpoint.rs50 D::Error: Into<crate::BoxError>, in new() argument
374 crate::BoxError: From<C::Error> + Send, in connect_with_connector()
399 crate::BoxError: From<C::Error> + Send, in connect_with_connector_lazy()
/tonic/tonic/src/server/
H A Dgrpc.rs227 B::Error: Into<crate::BoxError> + Send, in unary()
271 B::Error: Into<crate::BoxError> + Send, in server_streaming()
311 B::Error: Into<crate::BoxError> + Send + 'static, in client_streaming()
345 B::Error: Into<crate::BoxError> + Send, in streaming()
370 B::Error: Into<crate::BoxError> + Send, in map_request_unary()
403 B::Error: Into<crate::BoxError> + Send, in map_request_streaming()
/tonic/tonic/src/transport/server/service/
H A Dtls.rs27 ) -> Result<Self, crate::BoxError> { in new() argument
59 pub(crate) async fn accept<IO>(&self, io: IO) -> Result<TlsStream<IO>, crate::BoxError> in accept()
/tonic/tonic/src/transport/service/
H A Dgrpc_timeout.rs31 S::Error: Into<crate::BoxError>,
34 type Error = crate::BoxError;
76 E: Into<crate::BoxError>,
78 type Output = Result<Res, crate::BoxError>;
/tonic/tonic-web/src/
H A Dlib.rs83 type BoxError = Box<dyn std::error::Error + Send + Sync>; typedef
/tonic/tonic/src/
H A Dlib.rs127 pub(crate) type BoxError = Box<dyn std::error::Error + Send + Sync>; typedef
H A Dbody.rs36 B::Error: Into<crate::BoxError>, in new() argument
/tonic/examples/src/h2c/
H A Dserver.rs80 type BoxError = Box<dyn std::error::Error + Send + Sync>; typedef
86 S::Error: Into<BoxError> + 'static,
/tonic/tonic/src/codec/
H A Ddecode.rs68 B::Error: Into<crate::BoxError>, in new_response() argument
84 B::Error: Into<crate::BoxError>, in new_empty() argument
100 B::Error: Into<crate::BoxError>, in new_request() argument
121 B::Error: Into<crate::BoxError>, in new() argument
/tonic/tonic/src/transport/
H A Derror.rs36 pub(crate) fn from_source(source: impl Into<crate::BoxError>) -> Self { in from_source()

12