From b60df56157ee1fd0bd4938799bac05a62fda91a1 Mon Sep 17 00:00:00 2001
From: lookshe <github@lookshe.org>
Date: Sat, 14 Mar 2015 20:45:20 +0100
Subject: initial commit from working version

---
 .../node_modules/redis/lib/parser/hiredis.js       | 46 ++++++++++++++++++++++
 1 file changed, 46 insertions(+)
 create mode 100644 signaling-server/node_modules/socket.io/node_modules/redis/lib/parser/hiredis.js

(limited to 'signaling-server/node_modules/socket.io/node_modules/redis/lib/parser/hiredis.js')

diff --git a/signaling-server/node_modules/socket.io/node_modules/redis/lib/parser/hiredis.js b/signaling-server/node_modules/socket.io/node_modules/redis/lib/parser/hiredis.js
new file mode 100644
index 0000000..cbb15ba
--- /dev/null
+++ b/signaling-server/node_modules/socket.io/node_modules/redis/lib/parser/hiredis.js
@@ -0,0 +1,46 @@
+/*global Buffer require exports console setTimeout */
+
+var events = require("events"),
+    util = require("../util"),
+    hiredis = require("hiredis");
+
+exports.debug_mode = false;
+exports.name = "hiredis";
+
+function HiredisReplyParser(options) {
+    this.name = exports.name;
+    this.options = options || {};
+    this.reset();
+    events.EventEmitter.call(this);
+}
+
+util.inherits(HiredisReplyParser, events.EventEmitter);
+
+exports.Parser = HiredisReplyParser;
+
+HiredisReplyParser.prototype.reset = function () {
+    this.reader = new hiredis.Reader({
+        return_buffers: this.options.return_buffers || false
+    });
+};
+
+HiredisReplyParser.prototype.execute = function (data) {
+    var reply;
+    this.reader.feed(data);
+    while (true) {
+        try {
+          reply = this.reader.get();
+        } catch (err) {
+          this.emit("error", err);
+          break;
+        }
+
+        if (reply === undefined) break;
+
+        if (reply && reply.constructor === Error) {
+            this.emit("reply error", reply);
+        } else {
+            this.emit("reply", reply);
+        }
+    }
+};
-- 
cgit v1.2.3