0.1.0 • Published 6 years ago
mingo-stream v0.1.0
mingo-stream
NodeJS 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