fix

Author: felixs8696

examples/tutorials/00_sync/020_streaming/project/acp.py

@@ -90,10 +90,12 @@ async def handle_message_send(
     ):
         if chunk and chunk.choices and chunk.choices[0].delta and chunk.choices[0].delta.content:
             yield StreamTaskMessageDelta(
+                type="delta",
                 index=message_index,
                 delta=TextDelta(text_delta=chunk.choices[0].delta.content or ""),
             )
 
     yield StreamTaskMessageDone(
+        type="done",
         index=message_index,
     )

src/agentex/lib/sdk/fastacp/base/base_acp_server.py

@@ -332,7 +332,7 @@ async def message_send_wrapper(params: SendMessageParams):
 
                 async def async_generator(task_message_content_list: list[TaskMessageContent]):
                     for i, task_message_content in enumerate(task_message_content_list):
-                        yield StreamTaskMessageFull(index=i, content=task_message_content)
+                        yield StreamTaskMessageFull(type="full", index=i, content=task_message_content)
 
                 return async_generator(task_message_content_list)