Streaming STT

val stream = RunAnywhere.stt.openStream(
    AudioFormatSpec(encoding = AudioEncoding.PcmF32Le, sampleRate = 16000, channels = 1)
)

// per buffer
stream.pushFrame(AudioFrame(samples = bytes, sampleCount = count))

// when the utterance ends
stream.flush()
stream.finish()
stream.close()

RunAnywhere.stt.transcribeStream(audioFlow).collect { event ->
    when (event) {
        is TranscriptionEvent.Partial -> preview = event.text
        is TranscriptionEvent.Final -> transcript += event.transcription.text
        else -> {}
    }
}

fun openStream(format: AudioFormatSpec, options: SttOptions? = null): SttStream
fun transcribeStream(audio: Flow<AudioInput>, options: SttOptions? = null): Flow<TranscriptionEvent>

class LiveTranscriber : ViewModel() {
    private val _text = MutableStateFlow("")
    val text = _text.asStateFlow()

    fun start() {
        viewModelScope.launch(Dispatchers.IO) {
            val stream = RunAnywhere.stt.openStream(
                AudioFormatSpec(AudioEncoding.PcmF32Le, 16000, 1)
            )

            val recorder = AudioRecord(/* … */)
            recorder.startRecording()

            try {
                val buffer = ByteArray(4096)
                while (isActive) {
                    val read = recorder.read(buffer, 0, buffer.size)
                    if (read > 0) {
                        stream.pushFrame(AudioFrame(buffer.copyOf(read), read / 4))
                    }
                }
            } finally {
                stream.flush()
                stream.finish()
                stream.close()
                recorder.stop()
                recorder.release()
            }
        }
    }
}