		{
		"name": "level-live-stream",
		"version": "1.4.9",
		"version": "1.4.11",
		"homepage": "https://github.com/dominictarr/level-live-stream",
		@@ -10,8 +10,9 @@ "repository": {
		"dependencies": {
		"pull-stream-to-stream": "~1.2.4",
		"pull-level": "~1.1.10"
		"level-sublevel": "~6.3.1",
		"pull-level": "^1.4.1",
		"pull-stream-to-stream": "~1.2.4"
		},
		"devDependencies": {
		"level-sublevel": ">=4.0.2",
		"level-test": "~1.4.0"
		"level-test": "^2.0.0"
		},
		@@ -18,0 +19,0 @@ "scripts": {

+26

-8

test/index.js

		@@ -9,17 +9,35 @@ var LiveStream = require('../')
		var k = 10


		LiveStream(db, {tail: true}).on('data', function (data) {
		assert.equal(data.key, j--)
		console.log(data)
		if(data.type === 'put')
		assert.equal(data.key, j--)
		})

		LiveStream(db, {old: false}).on('data', function (data) {
		assert.equal(data.key, k--)
		if(data.type === 'put')
		assert.equal(data.key, k--)
		})

		var a = []
		var int = setInterval(function () {
		db.put(i+'', new Date(), function(err) {
		assert(err == undefined)
		})
		if(--i) return
		clearInterval(int)
		var key = i + ''

		if(Math.random() < 0.2 && a.length) {
		var r = ~~(Math.random()*a.length)
		key = a[r]
		a.slice(r, 1)
		db.del(key, function (err) {
		assert(err == undefined)
		})
		}
		else {
		a.push(key)
		db.put(key, new Date(), function(err) {
		assert(err == undefined)
		})
		if(--i) return
		clearInterval(int)
		}

		}, 100)

level-live-stream - npm Package Compare versions

Fixed alerts