diff --git a/async-openai/src/client.rs b/async-openai/src/client.rs
index 67488a9c..c09a70a4 100644
--- a/async-openai/src/client.rs
+++ b/async-openai/src/client.rs
@@ -763,6 +763,10 @@ where
                             break;
                         }
 
+                        if message.event == "keepalive" {
+                            continue;
+                        }
+
                         let response = match serde_json::from_str::<O>(&message.data) {
                             Err(e) => Err(map_deserialization_error(e, message.data.as_bytes())),
                             Ok(output) => Ok(output),