java - OkHttp3 身份 validator 与 RxJava

Question

我有一个 TokenProvider 方法:

public Observable<Token> authWithRefreshToken() {
    [...]
    return makeOAuth2Call(source);
}

OkHttp 的 Authenticator 实现如下所示:

@Override
public Request authenticate(Route route, Response response) throws IOException {

    Observable<Token> tokenObservable = tokenProvider.authWithRefreshToken();

    return response.request().newBuilder()
            .header("Authorization", "Bearer " + "HERE_I_HAVE_TO_SET_THE_TOKEN")
            .build();
}

基本上，我的问题是:如何做对？我能以某种方式同步接收 token 吗？当然我可以更改我的 OAuth API，但我只是好奇。

Answer 1

所以在搜索了一段时间后我发现了这个:

@Override
public Request authenticate(Route route, Response response) throws IOException {

    Token tokenObservable = tokenProvider.authWithRefreshToken().toBlocking().first();

    return response.request().newBuilder()
            .header("Authorization", "Bearer " + tokenObservable.getRefresh_token())
            .build();
}

正如 toBlocking 的文档所说:

Converts an Observable into a BlockingObservable (an Observable with blocking operators).