Hello I have a simple question ```fun main() { val observable = Observable.create<Int> { e...

# coroutines

[ahmad]

Hello I have a simple question

fun main() {
    val observable = Observable.create<Int> { emitter ->
        for (i in 1..5) {
            emitter.onNext(i)
        }
        emitter.onComplete()
    }
    observable.asFlow().onEach {
        println("Flow: $it")
    }
}

Why this code doesn’t print anything?

[octylFractal]

onEach is not a terminal operator, you probably want collect (extension function variant, not the internal coroutines API)

[octylFractal]

note that collect requires a suspend context, so you will probably also need suspend fun main

[ahmad]

I tried that

fun main() {
    val observable = Observable.create<Int> { emitter ->
        for (i in 1..5) {
            emitter.onNext(i)
        }
        emitter.onComplete()
    }

    GlobalScope.launch {
        observable.asFlow().collect {
            println("Flow: $it")
        }
    }
}

It didn’t print anything

[octylFractal]

yes, because launch is async -- main is exiting before launch gets to start

[ahmad]

Aha okay .. thank you 🙏

[Marcelo Hernandez]

Have you tried using runBlocking?

[octylFractal]

runBlocking is another solution, it's similar to suspend fun main

[ahmad]

yes got it .. thanks guys