Method _take_event

tutorials/10_sse_streaming.py:241–268

提取当前积累的事件数据，组装成 SseEvent。 提取后重置内部状态，准备解析下一个事件。 对应源码: runtime/sse.rs:82-96 (take_event)

(self)

        # 其他未知字段直接忽略（SSE 规范要求的）

    def _take_event(self) -> Optional[SseEvent]:
        """
        提取当前积累的事件数据，组装成 SseEvent。
        提取后重置内部状态，准备解析下一个事件。

        对应源码: runtime/sse.rs:82-96 (take_event)
        """
        # 如果什么数据都没有，说明没有有效事件
        if not self._data_lines and not self._event_name and not self._id and self._retry is None:
            return None

        # 多行 data 用换行符拼接（SSE 规范）
        data = "\n".join(self._data_lines)
        self._data_lines = []

        event = SseEvent(
            event=self._event_name,
            data=data,
            id=self._id,
            retry=self._retry,
        )

        # 重置状态
        self._event_name = None
        self._id = None
        self._retry = None

        return event


# ============================================================