Add Error::WsOther to wrap unexpected WS errors

kube-rs · Jan 5, 2021 · ed3f44d · ed3f44d
1 parent d1a502e
commit ed3f44d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/kube/src/client/mod.rs b/kube/src/client/mod.rs
@@ -166,9 +166,7 @@ impl Client {
                 | ws2::Error::AlreadyClosed
                 | ws2::Error::Utf8
                 | ws2::Error::Capacity(_)
-                | ws2::Error::SendQueueFull(_) => {
-                    panic!("Unexpected {}", err);
-                }
+                | ws2::Error::SendQueueFull(_) => Err(Error::WsOther(err.to_string())),
             },
         }
     }

diff --git a/kube/src/error.rs b/kube/src/error.rs
@@ -74,6 +74,11 @@ pub enum Error {
     #[cfg(feature = "native-tls")]
     #[error("OpensslError: {0}")]
     OpensslError(#[from] openssl::error::ErrorStack),
+
+    /// Unexpected error from making WebSocket connection.
+    #[cfg(feature = "ws")]
+    #[error("Unexpected WebSocket error: {0}")]
+    WsOther(String),
 }
 
 #[derive(Error, Debug)]