Comparing version 0.1.0 to 0.1.1
@@ -70,3 +70,4 @@ const Q = require('q') | ||
function tryResolve() { | ||
if (!stats.pending) { cleanup() } | ||
// in streams ended and no operations pending? | ||
if (stats.inEnd && !stats.pending) { cleanup() } | ||
else tick() | ||
@@ -73,0 +74,0 @@ } |
{ | ||
"name": "charybdis", | ||
"author": "jden <jason@denizac.org>", | ||
"version": "0.1.0", | ||
"version": "0.1.1", | ||
"description": "drain an object stream and wrap it in a promise", | ||
@@ -6,0 +6,0 @@ "keywords": [ |
7058
137