socket: added leave

dkgaoqi · Dec 24, 2012 · ef96e3b · ef96e3b
1 parent 6046c38
commit ef96e3b
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/lib/socket.js b/lib/socket.js
@@ -195,11 +195,20 @@ Socket.prototype.join = function(room, fn){
  * Leaves a room.
  *
  * @param {String} room
+ * @param {Function} optional, callback
+ * @return {Socket} self
  * @api private
  */
 
-Socket.prototype.leave = function(room){
+Socket.prototype.leave = function(room, fn){
   debug('leave room %s', room);
+  var self = this;
+  this.adapter.del(this.id, room, function(err){
+    if (err) return fn && fn(err);
+    debug('left room %s', room);
+    self.joined.splice(self.joined.indexOf(room, 1));
+    fn && fn(null);
+  });
   return this;
 };