I could just `subscribeBy` with a complete `onNext...

# rx

[chris-hatton]

I could just subscribeBy with a complete onNext onError and onComplete implementation that calls the corresponding functions on the subject, but this feels wrong: exactly the kind of boilerplate that Rx is supposed to avoid.