dimsuz
06/25/2020, 5:54 PMval subject = PublishSubject.create<Int>()
Observable.merge(
Observable.just(1,2,3).doOnSubscribe { println("subscribed to observable") },
subject.doOnSubscribe { println("subscribed to subject") }
).subscribe {
println("received $it")
}
prints
subscribed to observable
received 1
received 2
received 3
subscribed to subject
Can I somehow ensure that subscrption to merge arguments happens first and only then emittion starts? I.e. I want this to print
subscribed to observable
subscribed to subject
received 1, 2, 3
Why: for example I want to post to subject from within Observable.just(1,3,4).doOnLast { subject.onNext(88) }
val subject = PublishSubject.create<Int>()
subject
.doOnSubscribe { println("subscribed to subject") }
.mergeWith(Observable.just(1,3,4).doOnSubscribe { println("subscribed to observable") })
.subscribe {
println("received $it")
}
ursus
06/26/2020, 7:30 AM