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

Question

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

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

我需要实现应该返回 Observable> 的方法，列表中的每部电影都会有流派列表。

我已经实现了这样的流，但我的解决方案是使用 Observable.from() 转换为 Observable，而不是使用 toList() 运算符转换为 Observable>。这个解决方案是 Not Acceptable ，因为我在第一种方法的幕后使用 SQLBrite 包装器进行 react 性 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() 将正常工作