now when I think about it, its a regular task queu...
# rx
u
now when I think about it, its a regular task queue, .. should I use flowable and force backpressure and buffer it?