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

packages/ssestream/ssestream.go

@@ -159,7 +159,7 @@ func (s *Stream[T]) Next() bool {
 			}
 			s.cur = nxt
 			return true
-		case "message_start", "message_delta", "message_stop", "content_block_start", "content_block_delta", "content_block_stop", "message":
+		case "message_start", "message_delta", "message_stop", "content_block_start", "content_block_delta", "content_block_stop", "message", "user.message", "user.interrupt", "user.tool_confirmation", "user.custom_tool_result", "agent.message", "agent.thinking", "agent.tool_use", "agent.tool_result", "agent.mcp_tool_use", "agent.mcp_tool_result", "agent.custom_tool_use", "agent.thread_context_compacted", "session.status_running", "session.status_idle", "session.status_rescheduled", "session.status_terminated", "session.error", "session.deleted", "span.model_request_start", "span.model_request_end":
 			var nxt T
 			s.err = json.Unmarshal(s.decoder.Event().Data, &nxt)
 			if s.err != nil {