Streaming TTS

import com.runanywhere.sdk.public.RunAnywhere
import com.runanywhere.sdk.public.extensions.synthesizeStream
import com.runanywhere.sdk.public.types.RATTSOptions

RunAnywhere.synthesizeStream(longText, RATTSOptions(language_code = "en-US")).collect { chunk ->
    audioPlayer.enqueue(chunk.audio_data.toByteArray())
    if (chunk.is_final) audioPlayer.drain()
}

fun RunAnywhere.synthesizeStream(
    text: String,
    options: RATTSOptions = RATTSOptions.defaults(),
): Flow<RATTSOutput>

import com.runanywhere.sdk.public.extensions.stopSynthesis

RunAnywhere.stopSynthesis()

import ai.runanywhere.proto.v1.CurrentModelRequest
import ai.runanywhere.proto.v1.ModelCategory
import com.runanywhere.sdk.public.extensions.currentModel

val voice = RunAnywhere.currentModel(
    CurrentModelRequest(category = ModelCategory.MODEL_CATEGORY_SPEECH_SYNTHESIS),
)
if (!voice.found) showVoicePicker()

class StreamingAudioPlayer(private val scope: CoroutineScope) {
    private val chunks = Channel<ByteArray>(Channel.UNLIMITED)

    init {
        scope.launch(Dispatchers.IO) {
            for (chunk in chunks) playChunk(chunk)
        }
    }

    fun enqueue(chunk: ByteArray) {
        chunks.trySend(chunk)
    }

    fun stop() {
        chunks.close()
    }

    private fun playChunk(chunk: ByteArray) {
        // Write to an AudioTrack opened at the stream's sample rate.
    }
}

suspend fun streamAndSpeak(prompt: String) = coroutineScope {
    val sentences = Channel<String>(Channel.UNLIMITED)
    val speaker = launch(Dispatchers.IO) {
        for (sentence in sentences) {
            runCatching { RunAnywhere.speak(sentence, ttsOptions) }
        }
    }

    val buffer = StringBuilder()
    RunAnywhere.generateStream(prompt, genOptions).collect { event ->
        if (event.token.isEmpty()) return@collect
        buffer.append(event.token)
        drainSentences(buffer, flush = false).forEach { sentences.send(it) }
    }
    drainSentences(buffer, flush = true).forEach { sentences.send(it) }

    sentences.close()
    speaker.join()
}