(self, stream: str)
| 1527 | ) |
| 1528 | |
| 1529 | async def handle_response_stream(self, stream: str): |
| 1530 | await self.handle_intervention() |
| 1531 | try: |
| 1532 | if len(stream) < 25: |
| 1533 | return # no reason to try |
| 1534 | response = DirtyJson.parse_string(stream) |
| 1535 | if isinstance(response, dict): |
| 1536 | await extension.call_extensions_async( |
| 1537 | "response_stream", |
| 1538 | self, |
| 1539 | loop_data=self.loop_data, |
| 1540 | text=stream, |
| 1541 | parsed=response, |
| 1542 | ) |
| 1543 | |
| 1544 | except Exception as e: |
| 1545 | pass |
| 1546 | |
| 1547 | @extension.extensible |
| 1548 | def get_tool( |
no test coverage detected