Searched refs:IE (Results 1 – 2 of 2) sorted by relevance
| /tonic/tonic/src/transport/server/ |
| H A D | io_stream.rs | 26 pub(crate) struct ServerIoStream<S, IO, IE>
28 S: Stream<Item = Result<IO, IE>>,
36 impl<S, IO, IE> ServerIoStream<S, IO, IE>
38 S: Stream<Item = Result<IO, IE>>,
53 IE: Into<crate::BoxError>, in poll_next_without_tls()
69 impl<S, IO, IE> Stream for ServerIoStream<S, IO, IE>
71 S: Stream<Item = Result<IO, IE>>,
73 IE: Into<crate::BoxError>,
145 async fn select<IO: 'static, IE>( in select()
146 incoming: &mut (impl Stream<Item = Result<IO, IE>> + Unpin), in select()
[all …]
|
| H A D | mod.rs | 594 I: Stream<Item = Result<IO, IE>>, in serve_with_incoming() argument
596 IE: Into<crate::BoxError>, in serve_with_incoming()
617 I: Stream<Item = Result<IO, IE>>, in serve_with_incoming_shutdown() argument
619 IE: Into<crate::BoxError>, in serve_with_incoming_shutdown()
627 async fn serve_internal<S, I, F, IO, IE, ResBody>( in serve_internal() argument
639 I: Stream<Item = Result<IO, IE>>, in serve_internal() argument
641 IE: Into<crate::BoxError>, in serve_internal()
926 I: Stream<Item = Result<IO, IE>>, in serve_with_incoming() argument
928 IE: Into<crate::BoxError>, in serve_with_incoming()
957 I: Stream<Item = Result<IO, IE>>, in serve_with_incoming_shutdown() argument
[all …]
|