Basically, I need the first emission to execute blockingly on my current thread and the following ones on the specified scheduler (which is the same as current thread). Maybe if I instead move all the calls to
BehavourSubject.onNext
to mainThread, it would work, but I doubt it