使用rxjs的顺序和依赖查询

Question

我试图在Firebase数据库上进行多个顺序和依赖的查询。这就是数据库的样子：

books : { book1: { title: 'Book 1', author: 'author1' } }
authors: { author1: { name: 'Author 1' } }

我想检索所有的图书，遍历它们，获取相关的作者名称，在每个图书对象中设置值，并返回一个包含图书对象的可观察数组。

getBooks(): Observable<Book[]> {
    return this._af.database
        .list('/books')
        .flatMap(e => e)
        .concatMap(e => this.getAuthor(e.author), (a, b) => {
            a.author = b.lastName;
            return a;
        });
}

Answer 1

如果列表(/books)返回类似[bookObj,bookObj]的数组，则需要获取每本书的作者信息，除非输出需要保留输入书籍的顺序，否则不需要concatMap。

  getBooks(): Observable<Book[]> {
    return this._af.database
      .list('/books')
      .flatMap(booksArr => Rx.Observable.from(booksArr))
      .flatMap(
        book => this.getAuthor(e.author),
        (book,a) => { 
          a.author = book.lastName; 
          return a; 
        }
      );
  }