fixed issue with consumption and added an example

Author: NathanGRomano

examples/consume.js

@@ -0,0 +1,44 @@
+var ok = require('assert').equal;
+
+var router = require('./..')();
+router.on(function (socket, args, next) {
+  //do something!
+  next();
+});
+router.on(function (sock, args, next) {
+  sock.emit('what', new Date);
+  // this next won't do us any good the emit was already called.
+  next();
+  setTimeout(function () {
+    sock.emit('what', new Date);
+  }, 1000);
+  sock.emit('what', new Date);
+});
+
+var io = require('socket.io')(3000);
+io.use(router);
+io.on('connection', function (socket) {
+  // this won't get called because the "echo" event will be consumed!
+  socket.on('echo', function (data) {
+    socket.emit('echo', data);  
+  });
+});
+
+setTimeout(function () {
+  var client = require('socket.io-client').connect('ws://localhost:3000');
+  client.on('connect', function () {
+    client.emit('echo', 'data');
+  });
+  client.on('echo', function (data) {
+    ok(data,'data');
+    console.log('we good');
+    process.exit();
+  });
+  var c = 0;
+  client.on('what', function (data) {
+    if (++c >= 3) {
+      console.log('we good');
+      process.exit();
+    }
+  });
+},1000);

lib/router.js

@@ -103,6 +103,8 @@ function Router () {
         debug('unwrapping the socket');
         socket.emit = socket.emit.emit;
       }
+      
+      socket.emit.done = true;
 
       emit.apply(socket, args); 
     });
@@ -113,6 +115,8 @@ function Router () {
 
     (function step (err) {
 
+      if (socket.emit.done) return;
+
       debug('current step %s of %s', i+1, len);
 
       function next (err) {
@@ -126,6 +130,7 @@ function Router () {
             }
           }
           else {
+            if (socket.emit.done) return;
             if ('function' === typeof cb) {
               cb(null, socket, args);
             }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "socket.io-events",
-  "version": "0.4.0",
+  "version": "0.4.1",
   "description": "Power your socket.io apps with express like event routing.",
   "main": "index.js",
   "scripts": {