【问题标题】:Mongoose Stream JSON DataMongoose 流 JSON 数据
【发布时间】:2018-03-07 08:54:37
【问题描述】:

您好,我有以下代码

var mq = DeviceData.find().lean().cursor();
mq.on('data', function(data) {
        //code to write to a stream  
}).on('end', function() {
        //code to write to a stream      
});

我应该在评论区放什么?我想我应该创建一个 wrtie 流。这个想法是向客户端发送数据流。

【问题讨论】:

    标签: node.js express mongoose stream


    【解决方案1】:

    其实你可以直接使用pipe方法如下

    var mq = DeviceData.find().lean().cursor().pipe(yourWritableStream);
    

    或来自我的食谱

    DeviceData.find({})
        .lean()
        .cursor()
        .pipe(new Writable({
          objectMode: true,
          write(data, encoding, next) {
            // do something with your data
            // call next
        }))
        .on('finish', () => {
          // you can do something when the stream ends
        })
    

    【讨论】:

    • 不能或可以?错别字?
    猜你喜欢
    • 2016-08-01
    • 2017-11-11
    • 1970-01-01
    • 1970-01-01
    • 2020-11-26
    • 1970-01-01
    • 1970-01-01
    • 2015-08-28
    • 1970-01-01
    相关资源
    最近更新 更多