promise - 将 Promise 流转换为值流

Question

我对 RxJs 有点陌生，我正在尝试混合 Promise 和 observables 的世界。

这是我想要的:
我有一个可观察对象(称为 clickObs )，它监听单击并作为结果询问数据库，生成一个 promise ，当数据库查询结束(成功)时，该 promise 解析为一个值。
因此，我的 observable 会从点击流中生成 promise 流，而我想要的是从该 observable 中生成相应解析值的流。

从过去关于 stackoverflow 的问题，我读到了 defer , flatMap , mergeAll , 和 fromPromise ，但无法理解如何阐明这四个来解决我的问题。

有什么建议？

Answer 1

您不应该需要所有四个，只需查看 flatMap 或其兄弟 flatMapLatest

clickObs.flatMapLatest(function() {
  //Access the db and return a promis
  return database.query(queryObj);
})
.subscribe(function(result) {
  //Result is implicitly flattened out
  /*Do something with the result*/
});

flatMap将隐式转换 promise 或类似数组的对象为 Observable并将结果序列展平。 FlatMapLatest类似但会忽略旧事件，如果新事件在前一个事件完成之前到达。