angular - 从可观察数组中获取一个对象

Question

如何编写一个接受 Observable<T[]> 的函数？并返回 Observable<T> ？

比如我有两个方法:

getTransactions(): Observable<Transaction[]>{
        ...
    }
getTransaction(id: number): Observable<Transaction>{
    return this.getTransactions().pipe(find(txn => txn.id === id));
}

我收到错误消息，类型“Observable”不可分配给类型“Observable”。类型“Transaction[] 不可分配给类型“Transaction”。 “Transaction[]”类型中缺少属性“id”。

据我所知，可观察管道函数(map、single、find、max 等)属于数据流(即，当可观察对象随时间发出多个项目时)并且在可观察对象发出时没有用一次单个项目(恰好是一个数组)。

写 getTransaction(id) 的正确方法是什么？功能？我试过:

let transactions : Transaction[] = [];
this.getTransactions().subscribe(txns => transactions=txns);
return of(transactions.find(txn => txn.id === id));

但这会导致错误提示“交易”未定义。我对 Angular 等很陌生，所以任何说明都有帮助。谢谢!

Stackblitz

我正在使用:
Angular CLI:6.0.3
Angular :6.0.1
rxjs: 6.1.0

Answer 1

您需要将可观察值视为数组流，而不是试图将其视为项目流。可观察对象中的值是单点数据，每个数据点都包含自己的数组。

getTransaction(id: number): Observable<Transaction>{
    return this.getTransactions().pipe(
        map(txs => txs.find(txn => txn.id === id))
    );
}

您在这里所做的是将流中的每个数组映射到具有与参数匹配的 ID 的任何项目。