android - 如何将 Observable 对象映射到 Flowable ？

Question

 private Observable< SimpleResource > resource;
 return resource.map(new Function<SimpleResource, Flowable<Data>>() {
  @Override
  public Flowable< Data > apply(SimpleResource resource) throws Exception {
    return resource.data().toFlowable();
  }
});


  Single<Data> data();

我需要有 Flowable 但我的结果是 Observable>

Answer 1

由于您提到 data() 返回一个 Single，您需要将所有单个流转换为一个大流。将流转换为流，我们一般使用flatmap操作符:

resource.flatMapSingle(
            new Function<SimpleResource, Single<Data>>() {
                @Override
                public Single<Data> apply(SimpleResource resource) throws Exception {
                    return resource.data();
                }
            }
    ).toFlowable(BackpressureStrategy.BUFFER);