Improvement suggestions

[ghost]

Unsubscribe single-use event handlers after use

--stream.on('close', closeHandler);
--stream.on('end', closeHandler);
++stream.once('close', closeHandler);
++stream.once('end', closeHandler);

Avoid unnecessary closure

    stream.on('data', function(data) {
      tasks.push(data);
      if (running < concurrency) {
        startNextTask();
      } else {
--        stream.pause();
++        this.pause();
      }
    });