chore(internal): improve support for streaming responses

Author: stainless-bot

src/increase/_base_client.py

@@ -127,10 +127,18 @@ def __iter(self) -> Iterator[ResponseT]:
         process_line = self._client._process_stream_line
         process_data = self._client._process_response_data
 
+        awaiting_ping_data = False
         for raw_line in response.iter_lines():
             if not raw_line or raw_line == "\n":
                 continue
 
+            if raw_line.startswith("event: ping"):
+                awaiting_ping_data = True
+                continue
+            if awaiting_ping_data:
+                awaiting_ping_data = False
+                continue
+
             try:
                 line = process_line(raw_line)
             except StopStreaming:
@@ -168,10 +176,18 @@ async def __iter(self) -> AsyncIterator[ResponseT]:
         process_line = self._client._process_stream_line
         process_data = self._client._process_response_data
 
+        awaiting_ping_data = False
         async for raw_line in response.aiter_lines():
             if not raw_line or raw_line == "\n":
                 continue
 
+            if raw_line.startswith("event: ping"):
+                awaiting_ping_data = True
+                continue
+            if awaiting_ping_data:
+                awaiting_ping_data = False
+                continue
+
             try:
                 line = process_line(raw_line)
             except StopStreaming: