code: function EmitContinuation (stream) {
  
    stream._processing++;
  
    var self = function (err, data) {
      if (err)
        self.err = err;
      else if (Array.isArray(data))
        self.data = data;
      else
        self.data = [data];
  
      self.done = true;
  
      stream._processing--;
  
      stream._next();
    };
    return self;
  }
docs: /* ========================================================================== *
  UTILITIES                                                                 *
  ==========================================================================