55
66from claude_agent_sdk .types import (
77 AssistantMessage ,
8+ StreamEvent ,
89 SystemMessage ,
910 TextBlock ,
1011 ToolUseBlock ,
@@ -141,14 +142,17 @@ class TestHandleMessageStreamEvent:
141142 async def test_handles_text_delta_stream_event (self , mock_app , mock_config ):
142143 agent_loop = AgentLoop (app = mock_app )
143144
144- message = MagicMock ()
145- message .event = {
146- "type" : ContentType .CONTENT_BLOCK_DELTA .value ,
147- "delta" : {
148- "type" : ContentType .TEXT_DELTA .value ,
149- "text" : "Hello world" ,
145+ message = StreamEvent (
146+ uuid = "test-uuid" ,
147+ session_id = "test-session" ,
148+ event = {
149+ "type" : ContentType .CONTENT_BLOCK_DELTA .value ,
150+ "delta" : {
151+ "type" : ContentType .TEXT_DELTA .value ,
152+ "text" : "Hello world" ,
153+ },
150154 },
151- }
155+ )
152156
153157 await agent_loop ._handle_message (message )
154158
@@ -160,14 +164,17 @@ async def test_handles_text_delta_stream_event(self, mock_app, mock_config):
160164 async def test_ignores_empty_text_delta (self , mock_app , mock_config ):
161165 agent_loop = AgentLoop (app = mock_app )
162166
163- message = MagicMock ()
164- message .event = {
165- "type" : ContentType .CONTENT_BLOCK_DELTA .value ,
166- "delta" : {
167- "type" : ContentType .TEXT_DELTA .value ,
168- "text" : "" ,
167+ message = StreamEvent (
168+ uuid = "test-uuid" ,
169+ session_id = "test-session" ,
170+ event = {
171+ "type" : ContentType .CONTENT_BLOCK_DELTA .value ,
172+ "delta" : {
173+ "type" : ContentType .TEXT_DELTA .value ,
174+ "text" : "" ,
175+ },
169176 },
170- }
177+ )
171178
172179 await agent_loop ._handle_message (message )
173180
0 commit comments