如何创建 Observables 并使用 Retrofit 后来的 RxJava 更新它们？

Question

基本上我需要创建一个没有初始值的 Observable 列表。我订阅了 Observables 列表，并将根据所有 Observables 的响应提供所需的结果。我使用 zip 运算符。

问题是我最初需要创建 Observables，将它们添加到列表中并使用 zip 运算符。只是后来我使用 Retrofit 进行网络请求，我需要更新列表中 observable 的值，这样我的整个 zip 运算符才能正常工作。

但是，我没有找到一种方法来强制使用 Retrofit 的响应更新列表中的 observable。这似乎很容易，但我没有找到任何解决方案..唯一的想法是使用大量主题并将它们添加到列表中......

 List<Observable<Object>> listObservables = new ArrayList<>();
    //Adding initial request
    Observable<Object> testObservable = RetrofitFactory.create().startProcess();
    listObservables.add(testObservable);

    Observable.concatDelayError(listObservables).subscribe(response ->
            {
                //This is where all results should be managed
                Log.d("response", String.valueOf(response));
            },
            error ->
            {
                Log.d("response", String.valueOf(error));
            });
    //Actual request occurs much later in application

    listObservables.get(0).subscribeOn(Schedulers.io()).
            observeOn(AndroidSchedulers.mainThread()).subscribe(response ->
    {
        // the response of this, should notify concatDelayError
        Log.d("respoonse", String.valueOf(response));
    });

Answer 1

如果我理解正确，您想实现子请求模型。对于此任务，您可以将运算符链分解为不同的执行流并将其组合回来，例如，使用zip 运算符。使用这种方法，您可以使用单独的触发器创建完全独立的数据流。

Subject<Event> eventSubject = PublishSubject.create();

Observable<TriggerObject> mainRequest = eventSubject.flatMap((event) -> 
        RetrofitFactory.create().startProcess());
Observable<FirstSubResult> firstSubRequest = mainRequest.flatMap(tigger -> {
    // make first sub request
});
Observable<SecondSubResult> secondSubRequest = mainRequest.flatMap(tigger -> {
    // make second sub request
});
Observable<CompleteResult> resultObservable = Observable.zip(firstSubRequest, secondSubRequest,
        // zip function
        (first, second) -> {
            // combine result of sub requests to complete result object  
        });

现在您可以按您的事件启动请求流程：

// post your event. On button clicked for evxample
eventSubject.doOnNext(yourEvent);

注意：这个答案显示了链接数据流序列的主要思想。这适用于其他类型的请求，您无需改造即可使用此方法