This snippet ``` val subject = PublishSubject.c...

# rx

[dimsuz]

This snippet

val 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) }

[dimsuz]

ah, or does this happen, because no threading/scheduling is done above? but still I'd like to be sure that subscriptions happen first

[dimsuz]

OK, answering my own question, looks like this have done it:

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]

its blocking code so yea

[ursus]

emit your subject after the subscribtion, likr normally on next line