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