diff --git a/src/omega/omega_connection.rs b/src/omega/omega_connection.rs
index a1c5a7d..9845567 100755
--- a/src/omega/omega_connection.rs
+++ b/src/omega/omega_connection.rs
@@ -323,7 +323,7 @@ impl OmegaConnection {
                     }
                 }
                 #[allow(non_snake_case)]
-                Some(Ok(Message::Close(_))) | None => continue,
+                Some(Ok(Message::Close(_))) | None => break,
                 Some(Err(_)) => break,
                 _ => {}
             }