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

Popular posts from this blog

timeout - Handshake_timeout on RabbitMQ using python and pika from remote vm -

gcc - MinGW's ld cannot perform PE operations on non PE output file -

c# - Search and Add Comment with OpenXML for Word -