Update reasoning content during streaming. Args: reasoning: Reasoning/thinking content from model
(self, reasoning: str)
| 141 | await self._trigger_refresh() |
| 142 | |
| 143 | async def update_reasoning(self, reasoning: str) -> None: |
| 144 | """Update reasoning content during streaming. |
| 145 | |
| 146 | Args: |
| 147 | reasoning: Reasoning/thinking content from model |
| 148 | """ |
| 149 | if not self.streaming_state: |
| 150 | return |
| 151 | |
| 152 | self.streaming_state.reasoning_content = reasoning |
| 153 | await self._trigger_refresh() |
| 154 | |
| 155 | async def stop_streaming(self, interrupted: bool = False) -> str: |
| 156 | """Stop streaming and return final content. |