node.js - 在 Nodejs 中将回调转换为 RX.Observable

Question

我正在做一个项目，该项目正在使用无法换出的第三方库。它实质上是转到 URL 源并返回数据。它不返回 promise 。它将返回的数据传递回匿名回调......不是你传递给函数的数据。

文档参差不齐，但这里是他们指导您使用他们的库的方式。

third-party(URLsource, selector, scope)(function(err, data){ /* work with data array here*/ });

目前，代码一团糟。这部分是为了回调 hell 和过度使用 promise 。

通过 observables 传输数据将有助于简化和清理这个项目......但我仍在学习 RXjs 以及 observables 的工作原理。

我认为这个问题很适合:

let datapull = Rx.Observable.bindNodeCallback(third-party);
let result = datapull(URLsource, selector, scope);
result.subscribe(result => console.log(result), e => console.log("Error: " + e)

但是，这不起作用，因为最后一个参数:

third-party(URLsource, selector, scope)

不是回调函数。

我如何将这个第三方函数的结果包装在 RX Observable 中？

Answer 1

您的使用示例表明第三方 API 函数返回一个接受回调的函数。

如果是这样，需要传递给bindNodeCallback的是第三方调用的结果，而不是函数本身:

let datapull = Rx.Observable.bindNodeCallback(thirdParty(URLsource, selector, scope));
let result = datapull();
result.subscribe(result => console.log(result), e => console.log("Error: " + e)