使用Retrofit和Rxjava在网络错误上显示对话框

Question

我们正在建立一个应用程序使用改型与服务器通信，如果有一个网络错误，一个对话框（等效地，一个吐司）应该显示和请求将重做后，用户点击对话框。问题是我们希望全局处理它，而不是在每个请求周围编写重复的代码。使用A.Bertucci在本问题中描述的onerrorreveseenext()和observable view事件看起来很完美，但不幸的是，它运行在reverfit.idle线程中，不能启动任何UI元素。有可能解决这个问题吗？

失败的例子：

public static <T> Func1<Throwable, ? extends Observable<? extends T>> retryOnNetworkError(final Activity activity, final Observable<T> toBeResumed) {
    return new Func1<Throwable, Observable<? extends T>>() {
        @Override
        public Observable<? extends T> call(Throwable throwable) {
            if (throwable instanceof RetrofitError &&
                    RetrofitUtils.isNetworkError((RetrofitError) throwable)) {

                return dialog(activity, R.string.dialog_title_network_error, R.string.dialog_msg_network_error)
                        .filter(ok -> ok)
                        .flatMap(ok -> toBeResumed);
            }
            return Observable.error(throwable);
        }
    };
}

public static Observable<Boolean> dialog(Context context, int title, int message) {
    return Observable.create((Subscriber<? super Boolean> subscriber) -> {
        final AlertDialog ad = new AlertDialog.Builder(context)
                .setTitle(title)
                .setMessage(message)
                .setPositiveButton(android.R.string.ok, (dialog, which) -> {
                    subscriber.onNext(true);
                    subscriber.onCompleted();
                })
                .setNegativeButton(android.R.string.cancel, (dialog, which) -> {
                    subscriber.onNext(false);
                    subscriber.onCompleted();
                })
                .create();
        // cleaning up
        subscriber.add(Subscriptions.create(ad::dismiss));
        ad.show();
    });
}

Answer 1

不能在可观察到的界面中显示UI元素。您需要在UI线程上运行它。我也遇到了同样的错误，下面是我的解决方案：

Activity.runOnUiThread(new Runnable() {
                        @Override
                        public void run() {
                            AlertDialog(Activity, "Information : ", R.drawable.box_info, "Empty !").show;
                        }
                    });  

 public Observable<Boolean> add(Objet myObj) {
    return Observable.create(new Observable.OnSubscribeFunc<Boolean>() {
        @Override
        public Subscription onSubscribe(Observer<? super Boolean> observer) {
            System.out.println("In Observable ! ");
            try {
                observer.onNext(MyObjet.callmethod()); //callMethod retunr a boolean
mActivity.runOnUiThread(new Runnable() {
                        @Override
                        public void run() {
                            MyAlertDialog(mActivity, "My Title : ", R.drawable.box_info, "My Text");
                        }
                    });
                observer.onCompleted();
            } catch (Exception e) {
                observer.onError(e);
                e.printStackTrace();
            }
            return Subscriptions.empty();
        }
    }).subscribeOn(Schedulers.threadPoolForIO());
}

使用此方法，您可以调用线程中的对话框。