RxJava 2，改造2 Retrolambda-将2个请求链接在一起

Question

第一个API调用返回一个元素列表，然后我想随后调用另一个API，在第一个API调用的列表的每个元素中返回一个String。我（想我）已经得到了它，所以它用列表的每个元素调用第二个应用编程接口调用，但是我不确定如何订阅它来获得第二个调用返回的结果。

discogsService.getSearchResults(searchTerm, mContext.getString(R.string.token))
                .observeOn(AndroidSchedulers.mainThread())
                .subscribeOn(Schedulers.io())
                // Turns the result into individual elements
                .flatMapIterable(RootSearchResponse::getSearchResults)
                // I believe this then calls .getRelease() with each ID string
                .map(result -> discogsService.getRelease(result.getId()));

改装接口：

public interface DiscogsService
{
    @GET("database/search?")
    Observable<RootSearchResponse> getSearchResults(@Query("q") String searchTerm, @Query("token") String token);

    @GET("releases/")
    Observable<Release> getRelease(@Query("release_id") String releaseId);
}

我不确定从这里去哪里。

我相信。订阅（…）然后使我能够获得可观察的

有没有一种方法可以让我直接从模型层返回每个可观察的对象，这样我就不需要有两个单独的。订阅（…） s？或者我应该使用两个单独的。订阅（…） s，因为我可以捕获它们两个上的错误？我只想要第二次通话的结果。

以下是我尝试过的完整代码：

在模型中：

discogsService.getSearchResults(searchTerm, mContext.getString(R.string.token))
                .observeOn(AndroidSchedulers.mainThread())
                .subscribeOn(Schedulers.io())
                .flatMapIterable(RootSearchResponse::getSearchResults)
                .subscribeOn(Schedulers.io())
                .map(result -> discogsService.getRelease(result.getId()))
                .subscribe(new Observer<Observable<Release>>()
                {
                    @Override
                    public void onSubscribe(Disposable d)
                    {

                    }

                    @Override
                    public void onNext(Observable<Release> value)
                    {
                        mainPresenter.addToRecyclerView(value);
                    }

                    @Override
                    public void onError(Throwable e)
                    {

                    }

                    @Override
                    public void onComplete()
                    {

                    }
                });

在演示者：

@Override
public void addToRecyclerView(Observable<Release> value)
{
    value       .observeOn(AndroidSchedulers.mainThread())
                .subscribeOn(Schedulers.io())
                .subscribe(new Observer<Release>()
                {
                    @Override
                    public void onSubscribe(Disposable d)
                    {

                    }

                    @Override
                    public void onNext(Release value)
                    {
                        Log.e(TAG, "Success! " + value);
                        results.add(value);
                    }

                    @Override
                    public void onError(Throwable e)
                    {
                        Log.e(TAG, "Error: " + e.toString());
                        Log.e(TAG, "Error: " + e.toString());
                    }

                    @Override
                    public void onComplete()
                    {

                    }
                });




Answer 1

我宁愿公开一个可见的

Observable<Release> getReleases(...) {
    return discogsService.getSearchResults(...)
        .flatMapIterable(RootSearchResponse::getSearchResults)
        .flatMap(result -> discogsService.getRelease(result.getId()));
}

演讲者只会订阅它：

getReleases
    .observeOn(AndroidSchedulers.mainThread())
    .subscribeOn(Schedulers.io())
    .subscribe(new Observer<Release>()
    {
        @Override
        public void onSubscribe(Disposable d)
        {

        }

        @Override
        public void onNext(Release value)
        {
            Log.e(TAG, "Success! " + value);
            results.add(value);
        }

        @Override
        public void onError(Throwable e)
        {
            Log.e(TAG, "Error: " + e.toString());
            Log.e(TAG, "Error: " + e.toString());
        }

        @Override
        public void onComplete()
        {

        }
    });

只有一个可以观察到。注意，对于getReleases（…）中的第二个请求，从map（）切换到flatMap（） 。在幕后，这是发生第二次订阅的地方。

最终订阅将接收来自两个请求的错误。我更喜欢让消费者（演示者）处理错误，因为他们关心响应，知道在出现错误时该怎么做（例如显示消息）。

这是一个谁'驱动'观察，谁创造，处置它，所以这也是他的职责分配线程imho。

从一层暴露到另一层，可观察性非常好。它描述了数据类型、如何使用它以及模式（可观察？单一？流动？）。