1

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

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

我需要实现应该返回 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();

4

1 回答 1

3 
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() 将正常工作

于 2016-06-20T15:03:56.670 回答