RxJava，平面地图的好用例

Question

我是RxJava的新手，经常被平面图函数弄糊涂。根据文档，平面图将可观察对象发出的项目转换为可观察对象，然后将这些项目的排放平面化为单个可观察对象

有人能给出一个很好的用例吗？为什么要将原来的可观察对象转换为可观察对象（复数），然后将它们转换为单个可观察对象。

你为什么不直接用“地图”呢？

如果你举一个Android的例子，那就太棒了，否则纯Java就足够了。谢谢

Answer 1

我经常使用它将一些UI事件转换为可观察的后台任务：

ViewObservable.clicks(calculateBtn)
    .flatMap(new Func1<OnClickEvent, Observable<Integer>>() {
      @Override
      public Observable<Integer> call(OnClickEvent onClickEvent) {
          return observeBackgroundOperation()
            .observeOn(AndroidSchedulers.mainThread())//interaction with UI must be performed on main thread
            .doOnError(new Action1<Throwable>() {//handle error before it will be suppressed
                @Override
                public void call(Throwable throwable) {
                    progress.setVisibility(View.GONE);
                    calculateBtn.setEnabled(true);
                    Toast.makeText(IOCombineSampleActivity.this, R.string.mix_error_message, Toast.LENGTH_SHORT).show();
                }
            })
            .onErrorResumeNext(Observable.<Integer>empty());//prevent observable from breaking
      }
    })
    .subscribe(new Action1<Integer>() {...});

因为使用可观察很容易定义后台操作，所以我使用平面地图将按钮单击事件转换为“在后台事件中完成的事情”（例如通过Retrofit完成的网络请求），然后观察它们。

请注意，在平面图中可以观察到的可以发出单个值，这是在示例中完成的。

通过这种方式，我以声明方式定义了UI和后台进程之间的交互。我使用错误处理错误，然后使用错误恢复下一步（可观察）。

您可以在我的文章中找到完整的代码示例。

Answer 2

假设你有一个

Observable<Foo> fooObservable;

并且您想调用另一个方法，该方法采用Foo并发出可观察的

类似于：

public Observable<Bar> getBars(Foo foo);

如果您这样做了：

fooObservable.map(foo -> getBars(foo));

你最终会得到一个可观察的

相反，您可以使用“展平可观察对象”的平面图：

Observable<Bar> barObservable = fooObservable.flatMap(foo -> getBars(foo));

Answer 3

我在你的问题上看到了标签Android。因此，您可能应该熟悉改装。

让我们想象一下，您有两种方法：

public interface FoxreyRestApi {

    @POST("/signin")
    Observable<SignInResponse> signin(@Body SignInRequest request);

    @GET("/user")
    Observable<User> getUser(String accessToken);
}

您想获取用户数据，但需要accessToken，它返回的是SignInResponse。

你可以这样做：

1). 创建您的重新适配器。

2). 逐个执行查询：

restAdapter.signin(request)
    .flatMap(r -> restAdapter.getUser(r.getAccessToken()))
    .subscribe(user -> {/*User your user*/});