rx java - RxJava Can subscribe() on an Observable.empty() call onComplete() before the onSubscribe() returns a Subscription causing a NullPointerException? -
i writing logic merges 2 observables can make sure both run , complete whole. this, have used observable.mergedelayerror()
seen below. however, when writing unit tests, sometimes, nullpointerexception
when trying call mrefreshsubscription.unsubscribe()
mrefreshsubscription
null.
question: possible resulting merged observable, because can double empty, proceed call oncomplete()
faster subscribe()
returns subscription?
observable observa = observable.empty(); observable observb = observable.empty(); mrefreshsubscription = observable.mergedelayerror(observa, observb) .subscribeon(schedulers.io()) .observeon(schedulers.io()) .subscribe(getrefreshobserver()); private observer getrefreshobserver() { if (mrefreshobserver == null) { mrefreshobserver = new observer() { @override public void oncompleted() { mrefreshsubscription.unsubscribe(); } @override public void onerror(throwable e) { mrefreshsubscription.unsubscribe(); } @override public void onnext(object o) { // nothing } }; } return mcleanandautosubscriberobserver; }
Comments
Post a Comment