Comparing version 0.1.16 to 0.1.17
@@ -133,3 +133,7 @@ // A thing that emits "entry" events with Reader objects | ||
entry.on("stat", function (props) { | ||
me.emit("entryStat", entry, props) | ||
me.emit("_entryStat", entry, props) | ||
if (entry._aborted) return | ||
if (entry._paused) entry.once("resume", function () { | ||
me.emit("entryStat", entry, props) | ||
}) | ||
}) | ||
@@ -136,0 +140,0 @@ |
@@ -203,13 +203,21 @@ | ||
// last chance to abort or disown before the flow starts! | ||
me.emit("stat", props) | ||
if (me._aborted) { | ||
me.emit("end") | ||
me.emit("close") | ||
return | ||
} | ||
var events = ["_stat", "stat", "ready"] | ||
var e = 0 | ||
;(function go () { | ||
if (me._aborted) { | ||
me.emit("end") | ||
me.emit("close") | ||
return | ||
} | ||
me.emit("ready", props) | ||
if (me._paused) { | ||
me.once("resume", go) | ||
return | ||
} | ||
// if it's a directory, then we'll be emitting "entry" events. | ||
if (!me._paused) me._read() | ||
var ev = events[e ++] | ||
if (!ev) return me._read() | ||
me.emit(ev, props) | ||
go() | ||
})() | ||
} | ||
@@ -216,0 +224,0 @@ } |
@@ -5,3 +5,3 @@ { | ||
"description": "Advanced file system stream things", | ||
"version": "0.1.16", | ||
"version": "0.1.17", | ||
"repository": { | ||
@@ -8,0 +8,0 @@ "type": "git", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
62025
1818