lib/transaction.js
function add(err, req, res) {
  if(err) {
    // TODO: send args length errors

    // transaction errors are not queued
    // but the transaction is left open for more
    // command to be queued
    if(err instanceof TransactionError) {
      return res.send(err);
    }
    // last error
    this.error = err;
  }

  this.queue.push({err: err, req: req, res: res});
  res.send(null, QUEUED);
}
function add(err, req, res) {
  if(err) {
    // TODO: send args length errors

    // transaction errors are not queued
    // but the transaction is left open for more
    // command to be queued
    if(err instanceof TransactionError) {
      return res.send(err);
    }
    // last error
    this.error = err;
  }

  this.queue.push({err: err, req: req, res: res});
  res.send(null, QUEUED);
}
function add ( err , req , res ) { if ( err ) { // TODO: send args length errors // transaction errors are not queued // but the transaction is left open for more // command to be queued if ( err instanceof TransactionError ) { return res . send ( err ) ; } // last error this . error = err ; } this . queue . push ( { err : err , req : req , res : res } ) ; res . send ( null , QUEUED ) ; }
Queue a command.

The command and arguments list should already have been
validated to determine if an error would occur (EXECABORT).

@param err A validation error.
@param req The command request.
@param res The command response.
Queue a command .