Searched defs:Channel (Results 1 – 4 of 4) sorted by relevance
17 async fn streaming_echo(client: &mut EchoClient<Channel>, num: usize) { in streaming_echo()34 async fn bidirectional_streaming_echo(client: &mut EchoClient<Channel>, num: usize) { in bidirectional_streaming_echo()50 async fn bidirectional_streaming_echo_throttle(client: &mut EchoClient<Channel>, dur: Duration) { in bidirectional_streaming_echo_throttle()
66 pub struct Channel { struct72 /// This is returned by the `Service::call` on [`Channel`]. argument77 impl Channel { implementation207 impl Service<http::Request<Body>> for Channel { implementation233 impl fmt::Debug for Channel { implementation
350 pub async fn connect(&self) -> Result<Channel, Error> { in connect()358 pub fn connect_lazy(&self) -> Channel { in connect_lazy()369 pub async fn connect_with_connector<C>(&self, connector: C) -> Result<Channel, Error> in connect_with_connector()
136 pub async fn mock_io_channel(client: tokio::io::DuplexStream) -> Channel { in mock_io_channel()