Well okay... I can't believe I've had to write thi...

# rx

[chris-hatton]

Well okay... I can't believe I've had to write this extension function as you'd think it would be one of the most basic, core functions already in Rx but...

fun <T> Observable<T>.disposableSubscribe(observer:Observer<T>) : Disposable {
    return this.subscribe(observer::onNext,observer::onError,observer::onComplete)
}