mingo-stream

mingo-stream

Streaming functionality for Mingo query library

install

npm install mingo-stream

Stream Filtering

This example uses the JSONStream package

var JSONStream = require('JSONStream')
var fs = require('fs')
var Mingo = require('mingo')

require('mingo-stream')

var query = new Mingo.Query({
  scores: { $elemMatch: {type: "exam", score: {$gt: 90}} }
}, {name: 1})

file = fs.createReadStream('./students.json')

var qs = query.stream();
qs.on('data', function (data) {
    console.log(data); // log filtered outputs
    // ex. { name: 'Dinah Sauve', _id: 49 }
})

// file stream | json stream | query stream
file.pipe(JSONStream.parse("*")).pipe(qs)

License

MIT