SubscribeOn with rescheduling on producer.request

When a request(n) is invoked it now reschedules on the correct Scheduler