RxScala: Add backpressure support

As per #1603.

/cc @headinthebox, @samuelgruetter
Take a look at the subscribeOn implementation. It correctly scheduled the work back on to the Scheduler when a request is received.