to get queueing effect just create backpressure wi...
# rx
u
to get queueing effect just create backpressure with flatmap to observable on single thread, or concat map