MR
Из-за невнимательности при чтении доки, у меня была вот такая ситуация.
fun example() = callbackFlow<Any> {
Executors.newSingleThreadExecutor()
.execute {
while (true) {
offer(Any())
}
}
}
suspend fun main() {
scope.launch {
example()
.collect { println(it) }
}
delay(100)
scope.cancel()
}
Просто вместо Executors.newSingleThreadExecutor() были сокеты. Спасибо за помощь!