statejob.kt

val stateJob = flowToCallback(
  adapterScope, speechRecognizerStateFlow,
  speechRecognizerStateCallback
)
fun <T> flowToCallback(scope: CoroutineScope, flow: Flow<T>,
  callback: Consumer<T>): Job {
    return scope.launch {
      try {
        flow.collect {
          // invokes the closure which will call C calback
          callback.accept(it)
        }
      } catch (e: CancellationException) {
        println("collect cancelled")
      }
    }
}