如何以反应式方式使用Kotlin流实现RxJava间隔/无限计数器？

dependencies {
    implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:1.5.0'
    implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-android:1.5.0'
    implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-rx2:1.5.0'
}

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*

fun main() = runBlocking {
    val job = launch {
        flow {
            var counter = 0
            while (true) {
                emit(counter++)
                delay(1000) // 每隔1秒发射一个计数器值
            }
        }.collect {
            println(it)
        }
    }

    delay(5000) // 运行5秒后取消流
    job.cancel()
}