node.js - 通过 JavaScript 响应式(Reactive)扩展使用 Mongoose Stream

Question

我确信要使用 JavaScript 的响应式扩展，因此我尝试将它与 Mongoose 一起使用，如下所示:

var subscription = Rx.Node.fromStream(Meeting.find().stream())
.subscribe(function () {
  console.log(arguments);
});
subscription.dispose();

但是什么也没发生。我可能做错了什么？

Answer 1

找到解决方案:

Rx.Node.fromStream(Meeting.find().stream()).subscribe(function (data) {
  console.log(util.inspect(data, false, null));
});