You have to use synchronous sheduler. Try `.subscr...
# rx
d
You have to use synchronous sheduler. Try
.subscribeOn(immediate())
or
.subscribeOn(trampoline())