相关疑难解决方法(0)

在RXjava2中调用ObservableEmitter的onError时出现UndeliverableException

我有一个创建像下面的发射器的方法,有一个问题(也许这是正常的行为)在改装回调中调用onError.尝试调用onError时,我得到了UndeliverableException.

我可以通过检查subscriber.isDiposed()来解决这个问题,我想知道如何调用onError coz我需要通知我的UI级别.

  • 增加1
--> RxJava2CallAdapterFactoryalready implemented   
private static Retrofit.Builder builderSwift = new Retrofit.Builder()
           .baseUrl(URL_SWIFT)
           .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
           .addConverterFactory(GsonConverterFactory.create())
           .addConverterFactory(new ToStringConverterFactory());

--> When i added below code to application class app won't crash
--> but i get java.lang.exception instead of my custom exception  

RxJavaPlugins.setErrorHandler(Functions<Throwable>emptyConsumer());

@Override
    public void onFileUploadError(Throwable e) {
        Log.d(TAG, "onFileUploadError: " + e.getMessage());
    }
Run Code Online (Sandbox Code Playgroud)
public Observable<UploadResponseBean> upload(final UploadRequestBean uploadRequestBean, final File file) {
    return Observable.create(new ObservableOnSubscribe<UploadResponseBean>() {
        @Override
        public void subscribe(@NonNull final ObservableEmitter<UploadResponseBean> subscriber) throws Exception {

                 // ---> There …
Run Code Online (Sandbox Code Playgroud)

rx-android retrofit2 rx-java2

9
推荐指数
2
解决办法
4774
查看次数

标签 统计

retrofit2 ×1

rx-android ×1

rx-java2 ×1