Permalink
Browse files

The last commit broke tests - fixed

  • Loading branch information...
1 parent df3a028 commit 825af38a32eeb2123113a5d2b873350380c3ef07 @chriso chriso committed Nov 19, 2010
Showing with 2 additions and 0 deletions.
  1. +2 −0 lib/node.io/processor.js
View
@@ -486,6 +486,8 @@ Processor.prototype.jobComplete = function(job) {
for (var i in j.obj.output_streams) {
var stream = j.obj.output_streams[i];
+ if (!stream._queue) continue;
+
if (stream._queue.length === 0) {
stream.end();
} else {

0 comments on commit 825af38

Please sign in to comment.