要求对目标排放进行另一次改造

Question

我有以下课程：

public class SessionStore {
    Subject<Session, Session> subject;

    public SessionStore() {
       subject = new SerializedSubject<>(BehaviorSubject.create(new Session());
    }

    public void set(Session session) {
        subject.onNext(session);
    }

    public Observable<UserSession> observe() {
        return subject.distinctUntilChanged();
    }
}

在活动中，我观察会话并对每个更改执行网络操作：

private Subscription init() {
    return sessionStore
            .observe()
            .flatMap(new Func1<Session, Observable<Object>>() {
                @Override
                public Observable<Object> call(Session session) {
                    return (session.isValid() 
                       ? retrofitService.getThingForValid()
                       : retrofitService.getThingForInalid())
                       .subscribeOn(Schedulers.io());
                }
            })
            .subscribe(...);
}

现在我有一个Okhttp请求拦截器，当网络响应不是200代码时，我将会话实例从有效设置为无效。

事情是这样的:

< li >在初始订阅会话存储时，执行< code>getThingForValid()并失败。 < li>OkHttp截获失败并设置新的会话。 < li >会话存储发出一个新的现在无效的会话。 < li >新发射执行< code > getThingForInvalid()方法。

重要的是要知道，这个执行发生在前一个改造调用的中间。这是因为OkHttp客户端是由retrieve包装的，所有拦截器都是在retrievehtml" target="_blank">返回之前执行的。

考虑到这一点，您意识到第二个调用已经被reform执行和处理了，而第一个调用还没有完成。

我试图忽略流中的此异常，但无论如何，第二个调用都被Retrofit取消了。

你有任何想法如何使我的概念工作吗？

Answer 1

如果您在令牌过期的情况下获得响应代码401：您需要将身份验证器添加到OkHttpClient.Builder

builder.authenticator(new Authenticator() {
            @Override
            public Request authenticate(Route route, Response response) throws IOException {
                final LoginResponse newLoginResponse = refreshTokenClient.refreshToken();
                //save new token locally, if needed
                return response
                        .request()
                        .newBuilder()
                        .removeHeader("Api-Auth-Token") // removing old header
                        .addHeader("Api-Auth-Token", newLoginResponse.getAuthToken())
                        .build();
            }
        });

哪里

public interface RefreshTokenService {

   @PUT("/api/v1/tokens")
   LoginResponse refreshToken();

 }

但请注意：当响应代码为401时，此验证器。