class Filter: detect_reasoning_content = {} def stream(self, event: dict) -> dict: event_id = event.get("id") for choice in event.get("choices", []): delta = choice.get("delta", {}) value = delta.get("content", "") reasoning_value = delta.get("reasoning_content") if self.detect_reasoning_content.get(event_id, False): if reasoning_value is None: if event_id in self.detect_reasoning_content: del self.detect_reasoning_content[event_id] delta["content"] = f"</think>\n{value}" else: delta["content"] = reasoning_value elif reasoning_value is not None: self.detect_reasoning_content[event_id] = True delta["content"] = f"<think>\n{reasoning_value}" return event