将请求与 Retrofit2 和 RxJava2 相结合

Question

我试图用相同的观察者观察两个请求。我的观察者：

private BaseObserver<LoginResponse> loginObserver = new BaseObserver<LoginResponse>(this) {
    @Override
    public void onSubscribe(Disposable d) {
        super.onSubscribe(d);
        showLoading(true);
        Log.d(TAG, "onSubscribe: ");
    }

    @Override
    public void onNext(LoginResponse response) {
        super.onNext(response);
        Log.d(TAG, "onNext: ");
    }

    @Override
    public void onComplete() {
        super.onComplete();
        showLoading(false);
        Log.d(TAG, "onComplete: ");
    }

    @Override
    public void onError(Throwable e) {
        super.onError(e);
        showLoading(false);
    }
};

我的请求是使用Reformation 2构建的登录请求：

private void sendRequest(String username, String password) {
    IResourceAPI iResourceAPI = RetrofitClient.createIResourceClient(this);
    iResourceAPI.login(new LoginRequest(username, password))
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeWith(loginObserver);
}

现在我想启动2个或更多请求并在onNext中逐个检查响应，当检查最后一个请求时，使用我的观察者执行on完整。有人能帮我吗？

提前致谢。

Answer 1

听起来你好像在找合并运算符。

Answer 2

您正在寻找合并运算符：

通过使用Merge操作符，可以将多个可观察对象的输出组合起来，使它们像单个可观察对象一样工作。

只需修改您的请求，返回一个可观察值:

private Observable<LoginResponse> request(String username, String password) {
    IResourceAPI iResourceAPI = RetrofitClient.createIResourceClient(this);
    iResourceAPI.login(new LoginRequest(username, password))
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
}

然后合并：

Observable.merge<LoginResponse>(request(...), request(...))
    .subscribeWith(loginObserver);