fix(transport): connect w/ connector infailable (#922)
This commit is contained in:
@@ -185,8 +185,7 @@ async fn status_from_server_stream_with_source() {
|
||||
.unwrap()
|
||||
.connect_with_connector_lazy(tower::service_fn(move |_: Uri| async move {
|
||||
Err::<MockStream, _>(std::io::Error::new(std::io::ErrorKind::Other, "WTF"))
|
||||
}))
|
||||
.unwrap();
|
||||
}));
|
||||
|
||||
let mut client = test_stream_client::TestStreamClient::new(channel);
|
||||
|
||||
|
||||
@@ -346,7 +346,7 @@ impl Endpoint {
|
||||
///
|
||||
/// See the `uds` example for an example on how to use this function to build channel that
|
||||
/// uses a Unix socket transport.
|
||||
pub fn connect_with_connector_lazy<C>(&self, connector: C) -> Result<Channel, Error>
|
||||
pub fn connect_with_connector_lazy<C>(&self, connector: C) -> Channel
|
||||
where
|
||||
C: MakeConnection<Uri> + Send + 'static,
|
||||
C::Connection: Unpin + Send + 'static,
|
||||
@@ -359,7 +359,7 @@ impl Endpoint {
|
||||
#[cfg(not(feature = "tls"))]
|
||||
let connector = service::connector(connector);
|
||||
|
||||
Ok(Channel::new(connector, self.clone()))
|
||||
Channel::new(connector, self.clone())
|
||||
}
|
||||
|
||||
/// Get the endpoint uri.
|
||||
|
||||
Reference in New Issue
Block a user