a connection timeout should trigger a retry

streamnative · Feb 16, 2021 · 64d3edc · 64d3edc
1 parent 09e3b9b
commit 64d3edc
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/connection_manager.rs b/src/connection_manager.rs
@@ -240,7 +240,8 @@ impl<Exe: Executor> ConnectionManager<Exe> {
             {
                 Ok(c) => break c,
                 Err(ConnectionError::Io(e)) => {
-                    if e.kind() != std::io::ErrorKind::ConnectionRefused {
+                    if e.kind() != std::io::ErrorKind::ConnectionRefused ||
+                      e.kind() != std::io::ErrorKind::TimedOut {
                         return Err(ConnectionError::Io(e));
                     }