async def METHOD_NAME(
    self, prompt: str, **kwargs: Any
) -> CompletionResponseAsyncGen:
    # TODO: Implement async stream_complete
    async def gen() -> CompletionResponseAsyncGen:
        for response in self.stream_complete(prompt, **kwargs):
            yield response
    return gen()