Comparing version 2.3.0 to 2.3.1
@@ -227,3 +227,3 @@ 'use strict'; | ||
request.changes().run(this._db._connection, { includeStates: true }, (err, cursor) => { | ||
request.changes().run(this._db._connection, { includeStates: false, includeInitial: false }, (err, cursor) => { | ||
@@ -236,3 +236,2 @@ if (err) { | ||
let isReady = false; | ||
cursor.each((err, item) => { | ||
@@ -244,10 +243,3 @@ | ||
if (item.state) { | ||
isReady = (item.state === 'ready'); | ||
return; | ||
} | ||
if (isReady) { | ||
return each(null, { before: item.old_val || null, after: item.new_val || null }); | ||
} | ||
return each(null, { before: item.old_val || null, after: item.new_val || null }); | ||
}); | ||
@@ -254,0 +246,0 @@ |
{ | ||
"name": "penseur", | ||
"description": "Lightweight RethinkDB wrapper", | ||
"version": "2.3.0", | ||
"version": "2.3.1", | ||
"author": "Eran Hammer <eran@hammer.io> (http://hueniverse.com)", | ||
@@ -6,0 +6,0 @@ "repository": "git://github.com/hueniverse/penseur", |
65017
1494