概述

class PipelineProtocol(Protocol):
    def reply_stream(
        self,
        inputs: Msg
        | list[Msg]
        | UserConfirmResultEvent
        | UserInterruptEvent
        | ExternalExecutionResultEvent,
    ) -> AsyncGenerator[AgentEvent | Msg, None]:
        """回复输入，并流式产出过程中的事件。"""

async def watch(target: Agent | PipelineProtocol, inputs) -> None:
    # 两者的调用方式完全一致，无需区分
    async for event in target.reply_stream(inputs):
        print(event)