Home
last modified time | relevance | path

Searched refs:Connected (Results 1 – 9 of 9) sorted by relevance

/tonic/tonic/src/transport/server/
H A Dconn.rs51 pub trait Connected { trait
88 impl Connected for TcpStream {
99 impl Connected for tokio::io::DuplexStream {
106 impl<T> Connected for TlsStream<T>
108 T: Connected,
H A Dunix.rs1 use super::Connected;
20 impl Connected for tokio::net::UnixStream {
H A Dmod.rs21 pub use conn::{Connected, TcpConnectInfo};
595 IO: AsyncRead + AsyncWrite + Connected + Unpin + Send + 'static, in serve_with_incoming()
618 IO: AsyncRead + AsyncWrite + Connected + Unpin + Send + 'static, in serve_with_incoming_shutdown()
640 IO: AsyncRead + AsyncWrite + Connected + Unpin + Send + 'static, in serve_internal()
927 IO: AsyncRead + AsyncWrite + Connected + Unpin + Send + 'static, in serve_with_incoming()
958 IO: AsyncRead + AsyncWrite + Connected + Unpin + Send + 'static, in serve_with_incoming_shutdown()
1067 IO: Connected + 'static,
/tonic/tonic/src/transport/server/service/
H A Dio.rs1 use crate::transport::server::Connected;
52 IO: Connected,
83 pub(crate) enum ServerIoConnectInfo<IO: Connected> {
84 Io(<IO as Connected>::ConnectInfo),
86 TlsIo(<TlsStream<IO> as Connected>::ConnectInfo),
89 impl<IO: Connected> Clone for ServerIoConnectInfo<IO> {
111 IO: Connected, in connect_info()
/tonic/tests/integration_tests/src/
H A Dlib.rs14 use tonic::transport::server::Connected;
19 impl Connected for MockStream {
/tonic/tonic/src/transport/channel/service/
H A Dreconnect.rs29 Connected(S), enumerator
89 state = State::Connected(service); in poll_ready()
111 State::Connected(ref mut inner) => { in poll_ready()
147 let State::Connected(service) = &mut self.state else { in call()
H A Dio.rs6 use hyper_util::client::legacy::connect::{Connected as HyperConnected, Connection};
/tonic/tests/compression/src/
H A Dutil.rs18 use tonic::transport::{server::Connected, Channel};
/tonic/
H A DCHANGELOG.md362 * **transport:** Add `Connected` impl for `DuplexStream` ([#722](https://github.com/hyperium/tonic/…
569 * **transport:** Add Connected impl for TcpStream ([#245](https://github.com/hyperium/tonic/issues/…