vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/lib/parser/hiredis.js

   1 /*global Buffer require exports console setTimeout */
   2
   3 var events = require("events"),
   4     util = require("../util"),
   5     hiredis = require("hiredis");
   6
   7 exports.debug_mode = false;
   8 exports.name = "hiredis";
   9
  10 function HiredisReplyParser(options) {
  11     this.name = exports.name;
  12     this.options = options || {};
  13     this.reset();
  14     events.EventEmitter.call(this);
  15 }
  16
  17 util.inherits(HiredisReplyParser, events.EventEmitter);
  18
  19 exports.Parser = HiredisReplyParser;
  20
  21 HiredisReplyParser.prototype.reset = function () {
  22     this.reader = new hiredis.Reader({
  23         return_buffers: this.options.return_buffers || false
  24     });
  25 };
  26
  27 HiredisReplyParser.prototype.execute = function (data) {
  28     var reply;
  29     this.reader.feed(data);
  30     while (true) {
  31         try {
  32           reply = this.reader.get();
  33         } catch (err) {
  34           this.emit("error", err);
  35           break;
  36         }
  37
  38         if (reply === undefined) break;
  39
  40         if (reply && reply.constructor === Error) {
  41             this.emit("reply error", reply);
  42         } else {
  43             this.emit("reply", reply);
  44         }
  45     }
  46 };