firebase child readable stream

index.js

var PassThrough = require('stream').PassThrough

function createChildStream(ref) {
  var stream = new PassThrough({ objectMode: true })
  ref.limitToLast(1).once('child_added', function(snap) {
    var stopKey = snap.key()
    ref.on('child_added', function(snap) {
      stream.push(snap.val())
      if (snap.key() == stopKey) {
        ref.off('child_added')
        stream.end()
      }
    })
  })
  return stream
}