Home
last modified time | relevance | path

Searched refs:IO (Results 1 – 5 of 5) sorted by relevance

/tonic/tonic/src/transport/server/service/
H A Dio.rs49 impl<S, IO, ReqBody> Service<http::Request<ReqBody>> for ConnectInfo<S, ServerIoConnectInfo<IO>>
52 IO: Connected,
77 pub(crate) enum ServerIo<IO> {
78 Io(IO),
80 TlsIo(Box<TlsStream<IO>>),
84 Io(<IO as Connected>::ConnectInfo),
89 impl<IO: Connected> Clone for ServerIoConnectInfo<IO> {
99 impl<IO> ServerIo<IO> {
111 IO: Connected, in connect_info()
121 impl<IO> AsyncRead for ServerIo<IO>
[all …]
H A Dtls.rs59 pub(crate) async fn accept<IO>(&self, io: IO) -> Result<TlsStream<IO>, crate::BoxError> in accept() argument
61 IO: AsyncRead + AsyncWrite + Unpin, in accept()
/tonic/tonic/src/transport/server/
H A Dio_stream.rs23 struct State<IO>(TlsAcceptor, JoinSet<Result<ServerIo<IO>, crate::BoxError>>);
26 pub(crate) struct ServerIoStream<S, IO, IE>
28 S: Stream<Item = Result<IO, IE>>,
33 state: Option<State<IO>>,
36 impl<S, IO, IE> ServerIoStream<S, IO, IE>
38 S: Stream<Item = Result<IO, IE>>,
69 impl<S, IO, IE> Stream for ServerIoStream<S, IO, IE>
71 S: Stream<Item = Result<IO, IE>>,
75 type Item = Result<ServerIo<IO>, crate::BoxError>;
145 async fn select<IO: 'static, IE>( in select()
[all …]
H A Dmod.rs594 I: Stream<Item = Result<IO, IE>>, in serve_with_incoming()
617 I: Stream<Item = Result<IO, IE>>, in serve_with_incoming_shutdown()
639 I: Stream<Item = Result<IO, IE>>, in serve_internal()
767 fn serve_connection<B, IO, S, E>( in serve_connection() argument
768 hyper_io: IO, in serve_connection() argument
926 I: Stream<Item = Result<IO, IE>>, in serve_with_incoming()
957 I: Stream<Item = Result<IO, IE>>, in serve_with_incoming_shutdown()
1057 struct MakeSvc<S, IO> {
1062 _io: PhantomData<fn() -> IO>,
1065 impl<S, ResBody, IO> Service<&ServerIo<IO>> for MakeSvc<S, IO>
[all …]
/tonic/
H A DCHANGELOG.md634 * **transport:** Allow custom IO and UDS example ([#184](https://github.com/hyperium/tonic/issues/1…