1. module hiredis
   1. function hiredis.Reader ()
   2. function hiredis.createConnection (port, host)
   3. function hiredis.writeCommand ()
   4. object hiredis.Reader.prototype
2. module hiredis.Reader
   1. function hiredis.Reader ()
3. module hiredis.Reader.prototype
   1. function hiredis.Reader.prototype.feed ()
   2. function hiredis.Reader.prototype.get ()

module hiredis

function hiredis.Reader ()

• description and source-code

  Reader = function () { [native code] }

• example usage

  ...
  }
  
  return Buffer.concat(parts, size);
  }
  
  exports.createConnection = function(port, host) {
  var s = net.createConnection(port || 6379, host);
  var r = new hiredis.Reader();
  var _write = s.write;
  
  s.write = function() {
      var data = exports.writeCommand.apply(this, arguments);
      return _write.call(s, data);
  }
  ...

function hiredis.createConnection (port, host)

• description and source-code

  createConnection = function (port, host) {
      var s = net.createConnection(port || 6379, host);
      var r = new hiredis.Reader();
      var _write = s.write;
  
      s.write = function() {
          var data = exports.writeCommand.apply(this, arguments);
          return _write.call(s, data);
      }
  
      s.on("data", function(data) {
          var reply;
          r.feed(data);
          try {
              while((reply = r.get()) !== undefined)
                  s.emit("reply", reply);
          } catch(err) {
              r = null;
              s.emit("error", err);
              s.destroy();
          }
      });
  
      return s;
  }

• example usage

  ...
  var i = num_clients;
  var client;
  
  issued_requests = 0;
  test_start = new Date;
  while(i-- && issued_requests < num_requests) {
      active_clients++;
      client = hiredis.createConnection();
      call(client, test);
  }
  }
  
  function pipelined_test(test) {
  var client = hiredis.createConnection();
  var received_replies = 0;
  ...

function hiredis.writeCommand ()

• description and source-code

  writeCommand = function () {
      var args = arguments,
          bufLen = new Buffer(String(args.length), "ascii"),
          parts = [bufStar, bufLen, bufCrlf],
          size = 3 + bufLen.length;
  
      for (var i = 0; i < args.length; i++) {
          var arg = args[i];
          if (!Buffer.isBuffer(arg))
              arg = new Buffer(String(arg));
  
          bufLen = new Buffer(String(arg.length), "ascii");
          parts = parts.concat([
              bufDollar, bufLen, bufCrlf,
              arg, bufCrlf
          ]);
          size += 5 + bufLen.length + arg.length;
      }
  
      return Buffer.concat(parts, size);
  }

• example usage

  ...
  
  var assert = require("assert"),
  test = require("./testlib")(),
  hiredis = require("../hiredis");
  
  test("WriteCommand", function() {
  var reader = new hiredis.Reader();
  reader.feed(hiredis.writeCommand("hello", "world"));
  assert.deepEqual(["hello", "world"], reader.get());
  });
  
  test("WriteUnicode", function() {
  var reader = new hiredis.Reader();
  reader.feed(hiredis.writeCommand("béép"));
  assert.deepEqual(["béép"], reader.get());
  ...

module hiredis.Reader

function hiredis.Reader ()

• description and source-code

  Reader = function () { [native code] }

• example usage

  ...
  }
  
  return Buffer.concat(parts, size);
  }
  
  exports.createConnection = function(port, host) {
  var s = net.createConnection(port || 6379, host);
  var r = new hiredis.Reader();
  var _write = s.write;
  
  s.write = function() {
      var data = exports.writeCommand.apply(this, arguments);
      return _write.call(s, data);
  }
  ...

module hiredis.Reader.prototype

function hiredis.Reader.prototype.feed ()

• description and source-code

  function feed() { [native code] }

• example usage

  ...
  s.write = function() {
      var data = exports.writeCommand.apply(this, arguments);
      return _write.call(s, data);
  }
  
  s.on("data", function(data) {
      var reply;
      r.feed(data);
      try {
          while((reply = r.get()) !== undefined)
              s.emit("reply", reply);
      } catch(err) {
          r = null;
          s.emit("error", err);
          s.destroy();
  ...

function hiredis.Reader.prototype.get ()

• description and source-code

  function get() { [native code] }

• example usage

  ...
      return _write.call(s, data);
  }
  
  s.on("data", function(data) {
      var reply;
      r.feed(data);
      try {
          while((reply = r.get()) !== undefined)
              s.emit("reply", reply);
      } catch(err) {
          r = null;
          s.emit("error", err);
          s.destroy();
      }
  });
  ...