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

.

c.takeUntil(merged)

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

takeFirst(merged, c)

?

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

in side effect of the completing

merged

just cancel

c

disposable?

I've solved it.

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