我正在做一个项目，该项目正在使用无法换出的第三方库。它实质上是转到 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 中？
最佳答案
您的使用示例表明第三方 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)
关于node.js - 在 Nodejs 中将回调转换为 RX.Observable，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/39692929/