Annotate, persist, and return the response.
(self, response: BaseResponse)
| 34 | return self._conversation_service |
| 35 | |
| 36 | async def emit(self, response: BaseResponse) -> BaseResponse: |
| 37 | """Annotate, persist, and return the response.""" |
| 38 | |
| 39 | annotated = self._buffer.annotate(response) |
| 40 | await self._persist_from_buffer(annotated) |
| 41 | return annotated |
| 42 | |
| 43 | async def emit_many(self, responses: Iterable[BaseResponse]) -> list[BaseResponse]: |
| 44 | """Persist a batch of responses in order.""" |