A pull stream that writes to a leveldb instance, but only when it's actually a change.
var pull = require('pull-stream')
var level = require('level')
var db = level(path...)
pull(
source,
update(db, function (err, updateCount) {
//this callback is optional.
console.log(updateCount, 'records written')
})
)If you want to use this with ordinary streams, use pull-stream-to-stream
MIT