SpeechTranslator

class SpeechTranslator : Closeable

// 1. Initialize the client.
val options = speechTranslatorOptions(Locale.US, Locale.CHINESE)
val client = SpeechTranslation.getClient(options)

lifecycleScope.launch {
  try {
    // 2. Check the feature status and download the model if needed.
    if (client.checkStatus() == FeatureStatus.DOWNLOADABLE) {
      client.download().collect { status ->
        println("Download progress: $status")
      }
    }

    // 3. Construct the streaming request. Each TranslationAudio packet is tagged with the locale
    //    it was spoken in, which is what makes a single session bidirectional.
    val audioFlow = flow {
      emit(TranslationAudio(Locale.US, rawAudioBytes))
    }
    val request = speechTranslatorRequest(audioFlow)

    // 4. Start the session and collect responses.
    client.startTranslation(request).collect { response ->
      when (response) {
        is SpeechTranslatorResponse.Text -> {
          println("Translation (${response.locale}): ${response.translatedText}")
        }
        is SpeechTranslatorResponse.Audio -> {
          playAudio(response.audioBytes)
        }
        is SpeechTranslatorResponse.ErrorResponse -> {
          println("Failed: ${response.e.message}")
        }
        is SpeechTranslatorResponse.CompletedResponse -> {
          println("Session closed.")
        }
      }
    }
  } finally {
    // 5. Close the client when it is no longer needed.
    client.close()
  }
}