what I maybe see the problem with my code is if up...

# rx

[ursus]

what I maybe see the problem with my code is if upstream is coming from many threads, and each emit is flatmapped and then posted independently, meaning while downstream on main thread, orderind could be wrong