cp.rx.Observer.is(thing) -> boolean
thing
is an Observer
.true
if the thing is an Observer
, otherwise false
.cp.rx.Observer.create(onNext, onError, onCompleted) -> cp.rx.Observer
cp.rx.Observer:onCompleted() -> nil
cp.rx.Observer:onError(message) -> nil
cp.rx.Observer:onNext(...) -> nil