A `CompositeSubscription` per `onNext` when scheduling with `observeOn`. We need to eliminate this.