RxScala: Add backpressure support