r"""Handle the streaming response.
(generator: Stream[ChatCompletionChunk])
| 88 | |
| 89 | |
| 90 | def handle_streaming_response(generator: Stream[ChatCompletionChunk]): |
| 91 | r"""Handle the streaming response.""" |
| 92 | for completion in generator: |
| 93 | log.debug(f"Raw chunk completion: {completion}") |
| 94 | parsed_content = parse_stream_response(completion) |
| 95 | yield parsed_content |
| 96 | |
| 97 | |
| 98 | def get_all_messages_content(completion: ChatCompletion) -> List[str]: |
nothing calls this directly
no test coverage detected