[Feat]: google tts streaming with async client

[jayeshp19]

Saw this example using Google TTS streaming with Chirp3. I'm trying to do something similar with the async client but running into issues. Only the first sentence plays from iterator

Here’s a minimal repro:

import asyncio

from google.cloud import texttospeech


async def process_streaming_synthesis():
    client = texttospeech.TextToSpeechAsyncClient()

    streaming_config = texttospeech.StreamingSynthesizeConfig(
        voice=texttospeech.VoiceSelectionParams(
            name="en-US-Chirp3-HD-Charon",
            language_code="en-US",
        ),
        streaming_audio_config=texttospeech.StreamingAudioConfig(
            audio_encoding=texttospeech.AudioEncoding.OGG_OPUS
        ),
    )

    config_request = texttospeech.StreamingSynthesizeRequest(streaming_config=streaming_config)

    text_iterator = [
        "Hello there.",
        "How are you today?",
        "It's such nice weather outside.",
    ]

    async def request_generator():
        yield config_request
        for text in text_iterator:
            await asyncio.sleep(0)  # yield control to event loop
            yield texttospeech.StreamingSynthesizeRequest(
                input=texttospeech.StreamingSynthesisInput(text=text)
            )

    with open("output.ogg", "wb") as audio_file:
        stream = await client.streaming_synthesize(request_generator())
        async for response in stream:
            audio_file.write(response.audio_content)

    print("Complete audio saved to output.ogg")


def main():
    asyncio.run(process_streaming_synthesis())


if __name__ == "__main__":
    main()

Would really appreciate any pointers or working example. Thankss!

PTAL: @inardini @holtskinner

Code of Conduct

• I agree to follow this project's Code of Conduct

[jayeshp19]

Bumping this @holtskinner @inardini