rx.Observer.onNext
rx.Observer.onError
rx.Observer.onCompleted