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

Question

如何编写接受Observable 并返回Observable 的函数？

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 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的任何项。