UndeliverableException при загрузке растрового изображения: RxJava - PullRequest
Новая
       13

UndeliverableException при загрузке растрового изображения: RxJava

0 голосов
/ 03 мая 2018

У меня есть наблюдаемая цепочка, как показано ниже в моем фрагменте. У меня есть счетчик, который запускает Subject при выборе элемента, и, основываясь на этом выборе, я загружаю растровые изображения в Schedulers.computation() с помощью Picasso. 

Disposable d =  mSpinnerSelectionSubject.switchMap(selectedItem -> Observable.fromCallable(this::getImageDetails))
          .observeOn(Schedulers.computation())
          .switchMap(imageDetails -> Observable.fromCallable(() -> mPicasso.load(imageDetails.getImagePath()).get()))
          .observeOn(AndroidSchedulers.mainThread())
          .switchMap(this::setBitmapInView)
          .observeOn(Schedulers.computation())
          .switchMap(this::generateBitmaps) // this method does some opencv bitmap operation
          .observeOn(AndroidSchedulers.mainThread())
          .subscribeWith(new DisposableObserver<ImageData>() {
              @Override
              public void onNext(ImageData imageData) {
                  // do something
              }

              @Override
              public void onError(Throwable e) {
                  // handle error
              }

              @Override
              public void onComplete() {
                  Timber.d("onComplete: ");
              }
          }));

mCompositeDisposable.add(d);

Работает нормально, но иногда я получаю UndeliverableException. Я дал трассировку стека ниже. 

io.reactivex.exceptions.UndeliverableException: java.io.InterruptedIOException: thread interrupted
    at io.reactivex.plugins.RxJavaPlugins.onError(RxJavaPlugins.java:367)
    at io.reactivex.internal.operators.observable.ObservableFromCallable.subscribeActual(ObservableFromCallable.java:48)
    at io.reactivex.Observable.subscribe(Observable.java:11442)
    at io.reactivex.internal.operators.observable.ObservableSwitchMap$SwitchMapObserver.onNext(ObservableSwitchMap.java:126)
    at io.reactivex.internal.operators.observable.ObservableObserveOn$ObserveOnObserver.drainNormal(ObservableObserveOn.java:200)
    at io.reactivex.internal.operators.observable.ObservableObserveOn$ObserveOnObserver.run(ObservableObserveOn.java:252)
    at io.reactivex.internal.schedulers.ScheduledRunnable.run(ScheduledRunnable.java:66)
    at io.reactivex.internal.schedulers.ScheduledRunnable.call(ScheduledRunnable.java:57)
    at java.util.concurrent.FutureTask.run(FutureTask.java:237)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:272)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1133)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:607)
    at java.lang.Thread.run(Thread.java:761)
 Caused by: java.io.InterruptedIOException: thread interrupted
    at okio.Timeout.throwIfReached(Timeout.java:145)
    at okio.Okio$1.write(Okio.java:76)
    at okio.AsyncTimeout$1.write(AsyncTimeout.java:180)
    at okio.RealBufferedSink.flush(RealBufferedSink.java:224)
    at okhttp3.internal.http1.Http1Codec.finishRequest(Http1Codec.java:166)
    at okhttp3.internal.http.CallServerInterceptor.intercept(CallServerInterceptor.java:84)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
    at okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:45)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
    at okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:93)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
    at okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
    at okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:126)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
    at okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:200)
    at okhttp3.RealCall.execute(RealCall.java:77)
    at com.squareup.picasso.OkHttp3Downloader.load(OkHttp3Downloader.java:91)
    at com.squareup.picasso.NetworkRequestHandler.load(NetworkRequestHandler.java:46)
    at com.squareup.picasso.BitmapHunter.hunt(BitmapHunter.java:219)
    at com.squareup.picasso.RequestCreator.get(RequestCreator.java:429)
    at com.my.app.modules.detailscreen.DetailFragment.lambda$null$7$DetailFragment(Fragment.java:117)

Я попытался воспроизвести ошибку, и то, что я мог видеть, в основном это происходит, если я оставляю фрагмент во время загрузки растрового изображения.

Наблюдаемое, которое я добавляю к CompositeDisposable и во фрагменте 'onDestroyView' событие, которое я вызываю 

mCompositeDisposable.clear();

Также в событии onDestroy я делаю 

mCompositeDisposable.clear();

Я не понимаю, что именно вызвало аварию. Надеюсь, кто-нибудь может мне помочь. Заранее спасибо !!

1 Ответ

0 голосов
/ 03 мая 2018

Источник исключения: Observable.fromCallable(() -> mPicasso.load(imageDetails.getImagePath()).get()). Это происходит потому, что планировщик, на котором он работает, отправляет сигнал Thread.interrupt(), когда он удаляется, и оператор fromCallable перехватывает исключение и сигнализирует об этом независимо от того, была ли операция уже удалена.

Чтобы обойти это, вы можете вместо этого использовать Single.create, а затем вручную перехватывать и обрабатывать исключения с помощью метода SingleEmitter.tryOnError.

...