@elizarov, what should I do then? If I use RxJava, and then subscribe (not using consumeEach) both to a equivalent Flowable, everything works. In fact, I was trying to replace RxJava with Coroutines. But I couldn't implement an efficient bus and the code what I showed before.