0.1.0 • Published 12 years ago
mongo-stream v0.1.0
mongo-stream
Streaming interface to mongo
Example
var collection = require("mongo-col")
, from = require("read-stream").fromArray
, to = require("write-stream").toArray
, MongoStream = require("mongo-stream")
, someCollection = collection("name")
, someCollectionStream = MongoStream(someCollection)
, data = [{
some: "data"
}]
from(data)
.pipe(someCollectionStream.insert({ safe: true }))
.pipe(to([], function readList(list) {
console.log("inserted correctly", list)
someCollectionStream.find({ hello: "world" })
.pipe(to([], function readResult(list2) {
console.log("found correctly", list2)
}))
}))
Installation
npm install mongo-stream
Contributors
- Raynos
MIT Licenced
0.1.0
12 years ago