diff --git a/src/waylay/sdk/api/serialization.py b/src/waylay/sdk/api/serialization.py
index 519f6fe..12000dd 100644
--- a/src/waylay/sdk/api/serialization.py
+++ b/src/waylay/sdk/api/serialization.py
@@ -381,8 +381,6 @@ async def _iter_event_stream(
     response: Response,
     response_type: type[T],
     select_path: str = "",
-    *,
-    _ignore_retry_events: bool = True,
 ) -> AsyncIterator[T]:
     _response_type = _response_type_for_status_code(response.status_code, response_type)
     content_type = response.headers.get("content-type", "")
@@ -391,8 +389,6 @@ async def _iter_event_stream(
             event = __parse_event(event_str, content_type)
             if not event:
                 continue
-            if _ignore_retry_events and len(event) == 1 and "retry" in event:
-                continue
             _deserialized_event = _deserialize(
                 _extract_selected(event, select_path), _response_type
             )