Merge pull request #528 from innofluence/proxy

CustomEventEmitter.proxy method

.jshintrc

+{
+    "globals": {
+        "jasmine": false,
+        "spyOn": false,
+        "it": false,
+        "console": false,
+        "describe": false,
+        "expect": false,
+        "beforeEach": false,
+        "waits": false,
+        "waitsFor": false,
+        "runs": false
+    },
+    "camelcase": true,
+    "curly": true,
+    "forin": true,
+    "indent": 2,
+    "unused": true,
+    "asi": true,
+    "evil": false,
+    "laxcomma": true
+}
\ No newline at end of file

lib/emitters/custom-event-emitter.js

 var util         = require("util")
   , EventEmitter = require("events").EventEmitter
+  , proxyEventKeys = ['success', 'error', 'sql']
 
 module.exports = (function() {
   var CustomEventEmitter = function(fct) {
@@ -40,6 +41,14 @@ module.exports = (function() {
     return this
   }
 
+  CustomEventEmitter.prototype.proxy = function(emitter) {
+    proxyEventKeys.forEach(function (eventKey) {
+      this.on(eventKey, function (result) {
+        emitter.emit(eventKey, result)
+      })
+    }.bind(this))
+  }
+
 
   return CustomEventEmitter;
 })()

spec/emitters/custom-event-emitter.js

+if(typeof require === 'function') {
+  const buster             = require("buster")
+      , CustomEventEmitter = require("../../lib/emitters/custom-event-emitter")
+      , Helpers            = require('../buster-helpers')
+      , dialect            = Helpers.getTestDialect()
+}
+
+buster.spec.expose()
+buster.testRunner.timeout = 1000
+
+describe(Helpers.getTestDialectTeaser("CustomEventEmitter"), function() {
+	describe("proxy", function () {
+		/* Tests could _probably_ be run synchronously, but for future proofing we're basing it on the events */
+
+		it("should correctly work with success listeners", function (done) {
+			var emitter = new CustomEventEmitter()
+				, proxy = new CustomEventEmitter()
+				, success = this.spy()
+
+			emitter.success(success)
+			proxy.success(function () {
+				process.nextTick(function () {
+					expect(success.called).toEqual(true)
+					done();
+				})
+			})
+
+			proxy.proxy(emitter)
+			proxy.emit('success')
+		})
+
+		it("should correctly work with error listeners", function (done) {
+			var emitter = new CustomEventEmitter()
+				, proxy = new CustomEventEmitter()
+				, error = this.spy()
+
+			emitter.error(error)
+			proxy.error(function () {
+				process.nextTick(function () {
+					expect(error.called).toEqual(true)
+					done();
+				})
+			})
+
+			proxy.proxy(emitter)
+			proxy.emit('error')
+		})
+
+		it("should correctly work with complete/done listeners", function (done) {
+			var emitter = new CustomEventEmitter()
+				, proxy = new CustomEventEmitter()
+				, complete = this.spy()
+
+			emitter.complete(complete)
+			proxy.complete(function () {
+				process.nextTick(function () {
+					expect(complete.called).toEqual(true)
+					done();
+				})
+			})
+
+			proxy.proxy(emitter)
+			proxy.emit('success')
+		})
+	});
+});
\ No newline at end of file