chore: improve ws poll loop

akasamq · Nov 2, 2023 · 6fed349 · 6fed349
1 parent 93a7cfd
commit 6fed349
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/akasa-core/src/server/mod.rs b/akasa-core/src/server/mod.rs
@@ -380,8 +380,7 @@ impl<S: AsyncRead + AsyncWrite + Unpin> AsyncRead for WebSocketWrapper<S> {
                         Poll::Ready(Some(Ok(msg))) => match msg {
                             Message::Binary(bin) => {
                                 if bin.is_empty() {
-                                    cx.waker().wake_by_ref();
-                                    return Poll::Pending;
+                                    continue;
                                 }
                                 *read_data = bin;
                                 *read_data_idx = 0;