diff --git a/tonic/src/transport/service/discover.rs b/tonic/src/transport/service/discover.rs index 4088f8d..6ca4ab2 100644 --- a/tonic/src/transport/service/discover.rs +++ b/tonic/src/transport/service/discover.rs @@ -36,6 +36,7 @@ impl Stream for DynamicServiceStream { let mut http = hyper::client::connect::HttpConnector::new(); http.set_nodelay(endpoint.tcp_nodelay); http.set_keepalive(endpoint.tcp_keepalive); + http.set_connect_timeout(endpoint.connect_timeout); http.enforce_http(false); #[cfg(feature = "tls")] let connector = service::connector(http, endpoint.tls.clone());