通过JavaScript的无效扩展使用Mongoose Stream
我一直坚信使用Reactive Extensions for JavaScript,所以我试图像Mongoose一样使用它:
var subscription = Rx.Node.fromStream(Meeting.find().stream()) .subscribe(function () { console.log(arguments); }); subscription.dispose();
但没有任何反应。 我可能会做错什么?
find解决办法:
Rx.Node.fromStream(Meeting.find().stream()).subscribe(function (data) { console.log(util.inspect(data, false, null)); });