How to merge to kotlin coroutines together?

Question

I have 2 flows that i would like to merge like i used to do it in RxJava.

In Rx-Java:

Flowable.just(1).mergeWith(Flowable.just(2)).subscribe({ println(it)}) // result: 1, 2

How to replicate that in Kotlin Coroutines ? Thanks in advance.

John O'Reilly · Accepted Answer · 2019-09-04 15:46:43Z

3

flattenMerge should provide same behaviour. For example,

    val flow1 = (1..3).asFlow()
    val flow2 = (4..6).asFlow()
    flowOf(flow1, flow2).flattenMerge().collect { value ->
        println("$value")
    }

answered Sep 4, 2019 at 15:46

John O'Reilly

10.4k6 gold badges45 silver badges67 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

How to merge to kotlin coroutines together?

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related