kappa-view-query
Advanced tools
Comparing version 2.0.7 to 2.0.8
@@ -79,3 +79,6 @@ const through = require('through2') | ||
var thru = through.obj(function (msg, enc, next) { | ||
if (msg.sync) return next() | ||
if (msg.sync) { | ||
this.push(msg) | ||
return next() | ||
} | ||
@@ -82,0 +85,0 @@ var msgId = msg.value |
{ | ||
"name": "kappa-view-query", | ||
"version": "2.0.7", | ||
"version": "2.0.8", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -115,2 +115,3 @@ const { describe } = require('tape-plus') | ||
stream.on('data', (msg) => { | ||
if (msg.sync) return done() | ||
assert.same(check[count], msg.value, 'streams each message live') | ||
@@ -117,0 +118,0 @@ ++count |
136680
857