由于底层的 SQLBrite，无需使用 toList() 即可组合两个可观察对象

Question

1) 我有方法 Observable> moviesWithoutGenres() returns 电影列表，但电影的流派字段为空

2) 我有方法 Observable> movieGenres(Movie m) returns 指定字段的流派列表

我需要实现 returns Observable> 并且列表中的每部电影都会有流派列表的方法。

我已经实现了这样的流，但我的解决方案是使用 Observable.from() 转换为 Observable，而不是使用 toList() 运算符转换为 Observable>。这个解决方案是不可接受的，因为我在第一种方法的幕后使用 SQLBrite 包装器进行反应性 sql 查询。 onCompleted 不会被调用，因为流始终保持打开状态，以便可以将对 sql 表的更改传播到所有订阅者。因此，无法执行 toList 运算符。

public class Movie {
    private String id;
    private String title;
    private List<String> genres;
    ...
}

1) Observable<List<Movie>> moviesWithoutGenres();

2) Observable<List<String>> movieGenres(Movie m);

应该实施：

Observable<List<Movie>> movies();

Answer 1

public Observable<List<Movie>> movies() {
  return moviesWithoutGenres()
    .switchMap(movies -> Observable.from(movies) // This is an Observable<Movie>
      .concatMap(movie -> movieGenres(movie)
        .first()
        .map(genres -> new Movie(movie.id, movie.title, genres)))
      .toList());
}

Observable.from() 将发出列表中的项目，然后是 onComplete()。诀窍在于，由于 movieGenres 是一个无穷无尽的可观察对象，您必须 .first() 它以便调用 onComplete() 并且 toList() 将正常工作

由于底层的 SQLBrite，无需使用 toList() 即可组合两个可观察对象

Combine two observables without using toList() because of SQLBrite under the hood

java

android

sqlite

system.reactive

sqlbrite