RxJava通过匹配属性值加入可观察流。

Question

RxJava通过匹配属性值加入可观察流。

6

假设我有两个可观察的流。

Observable<Book> books;
Observable<Movie> movies;

我应该如何按匹配属性联接这些内容？类似下面的伪代码：

Observable<BookMoviePair> pairs = books.join(movies)
    .where((book, movie) -> book.getId() == movie.getId()))
    .return((book, movie) -> new BookMoviePair(book, movie));

- Theodor

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Egor Neliuba · Accepted Answer

一种实现方式：

Observable<BookMoviePair> pairs =
        books.flatMap(book -> movies
                .first(movie -> movie.getId() == book.getId())
                .map(movie -> new BookMoviePair(book, movie)));