如何将刷新令牌逻辑添加到RXJava+改型中？[副本]

Question

我是RxJava新手，但我喜欢它。而现在我有小问题了。我使用的是RxJava+retfit。

如果我有有效的用户令牌，我会得到API的响应，但如果令牌无效，我必须刷新令牌并尝试再次发出请求。

null

null

如何使用RXJava实现它？

Answer 1

试试这个有我的知识

service.normalRequest()
            .flatMap( new Func1<Response, Observable<Response>>() {
                @Override
                public Observable<Response> call(Response response) {
                    if (response.code() == 403) {
                        return service.refreshToken(refreshRequest)
                                .flatMap(new Func1<Response, Observable<Response>>() {
                                    @Override
                                    public Observable<Response> call(Response response) {
                                        return service.normalRequest();
                                    }
                                });

                    } else {
                        return Observable.just(response);
                    }

                }
            }).subscribeOn(Schedulers.io())
              .observeOn(AndroidSchedulers.mainThread())
              .subscribe(
                new Subscriber<Response>() {
                    @Override
                    public void onCompleted() {

                    }

                    @Override
                    public void onError(Throwable e) {

                    }

                    @Override
                    public void onNext(Response response) {

                }
            });