fix(streaming): add missing events

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 72
 openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/anthropic%2Fanthropic-dfe504526eed07979685a729ac9afd45e59cc2879291714b9f4674f2ef1247c7.yml
 openapi_spec_hash: d849fdf2c4dd6631a60c4340e9bc1322
-config_hash: 831f90480c5b2b863b726e89eabaa90c
+config_hash: 127053e0220d5d31aef47d21169f9f6c

src/core/streaming.ts

@@ -66,7 +66,27 @@ export class Stream<Item> implements AsyncIterable<Item> {
             sse.event === 'content_block_start' ||
             sse.event === 'content_block_delta' ||
             sse.event === 'content_block_stop' ||
-            sse.event === 'message'
+            sse.event === 'message' ||
+            sse.event === 'user.message' ||
+            sse.event === 'user.interrupt' ||
+            sse.event === 'user.tool_confirmation' ||
+            sse.event === 'user.custom_tool_result' ||
+            sse.event === 'agent.message' ||
+            sse.event === 'agent.thinking' ||
+            sse.event === 'agent.tool_use' ||
+            sse.event === 'agent.tool_result' ||
+            sse.event === 'agent.mcp_tool_use' ||
+            sse.event === 'agent.mcp_tool_result' ||
+            sse.event === 'agent.custom_tool_use' ||
+            sse.event === 'agent.thread_context_compacted' ||
+            sse.event === 'session.status_running' ||
+            sse.event === 'session.status_idle' ||
+            sse.event === 'session.status_rescheduled' ||
+            sse.event === 'session.status_terminated' ||
+            sse.event === 'session.error' ||
+            sse.event === 'session.deleted' ||
+            sse.event === 'span.model_request_start' ||
+            sse.event === 'span.model_request_end'
           ) {
             try {
               yield JSON.parse(sse.data) as Item;