我有一个创建像下面的发射器的方法,有一个问题(也许这是正常的行为)在改装回调中调用onError.尝试调用onError时,我得到了UndeliverableException.
我可以通过检查subscriber.isDiposed()来解决这个问题,我想知道如何调用onError coz我需要通知我的UI级别.
- 增加1
Run Code Online (Sandbox Code Playgroud)--> 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()); }
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)