Using rxjava observable collection issue

Can you share the exact exception you get and maybe some code to reproduce? There might be different exceptions thrown (especially a BackpressureException if you overload the request ringbuffer with a huge batch). And depending on what happens they might need to be treated differently. Maybe you can show us some logs as well?