Hello, guys! How could you do such thing? ``` val a: Completable val b: Completable val c: Completab...

# rx

[ilyagulya]

Hello, guys!
How could you do such thing?

val a: Completable
val b: Completable
val c: Completable

val merged = Completable.merge(listOf(a,b))

I need to subscribe to both merged and c but if merged completes before the c, I need to unsubscribe from c.

[kioba]

c.takeUntil(merged)

http://reactivex.io/documentation/operators/takeuntil.html

[Eugen Martynov]

takeFirst(merged, c)?

[ilyagulya]

@kioba thanks! That’s exactly what I need!

[ilyagulya]

@kioba oops, sorry, this behaves the same as takeFirst.

[ilyagulya]

@Eugen Martynov takeFirst will complete once any of completables are complete. I need merged to be completed for sure, but I don’t care if c will complete or not.

[Eugen Martynov]

in side effect of the completing merged just cancel c disposable?

[Eugen Martynov]

It will work and I don’t know any operator that will work as you said

[Eugen Martynov]

unless you make your own

[ilyagulya]

I've solved it.

merged
    .andThen(Completable.error(Exception()))
    .mergeWith(c)
    .onErrorComplete()