我确信要使用 JavaScript 的响应式扩展,因此我尝试将它与 Mongoose 一起使用,如下所示:
var subscription = Rx.Node.fromStream(Meeting.find().stream())
.subscribe(function () {
console.log(arguments);
});
subscription.dispose();
但是什么也没发生。 我可能做错了什么?
最佳答案
找到解决方案:
Rx.Node.fromStream(Meeting.find().stream()).subscribe(function (data) {
console.log(util.inspect(data, false, null));
});
关于node.js - 通过 JavaScript 响应式(Reactive)扩展使用 Mongoose Stream,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/25922641/