Searched refs:Io (Results 1 – 3 of 3) sorted by relevance
| /tonic/tonic/src/transport/server/service/ |
| H A D | io.rs | 64 ServerIoConnectInfo::Io(inner) => { in call()
78 Io(IO), enumerator
84 Io(<IO as Connected>::ConnectInfo), enumerator
92 Self::Io(io) => Self::Io(io.clone()), in clone()
101 Self::Io(io) in new_io()
114 Self::Io(io) => ServerIoConnectInfo::Io(io.connect_info()), in connect_info()
131 Self::Io(io) => Pin::new(io).poll_read(cx, buf), in poll_read()
148 Self::Io(io) => Pin::new(io).poll_write(cx, buf), in poll_write()
156 Self::Io(io) => Pin::new(io).poll_flush(cx), in poll_flush()
164 Self::Io(io) => Pin::new(io).poll_shutdown(cx), in poll_shutdown()
[all …]
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | io.rs | 8 pub(in crate::transport) trait Io: interface
13 impl<T> Io for T where T: rt::Read + rt::Write + Send + 'static {}
15 pub(crate) struct BoxedIo(Pin<Box<dyn Io>>);
18 pub(in crate::transport) fn new<I: Io>(io: I) -> Self { in new()
|
| /tonic/tonic/src/transport/server/ |
| H A D | io_stream.rs | 103 SelectOutput::Io(io) => Poll::Ready(Some(Ok(io))), in poll_next()
168 Ok(Ok(io)) => SelectOutput::Io(io), in select()
179 Io(ServerIo<A>), enumerator
|