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") reasoning_value = delta.get("reasoning_content", "") if reasoning_value: if self.detect_reasoning_content.get(event_id, False): delta["content"] = reasoning_value else: self.detect_reasoning_content[event_id] = True delta["content"] = f"<think>\n{reasoning_value}" elif self.detect_reasoning_content.get(event_id, False): if event_id in self.detect_reasoning_content: del self.detect_reasoning_content[event_id] value = delta.get("content", "") delta["content"] = f"</think>\n{value}" return event