reconstruct subchan

lib/index.js

@@ -98,6 +98,7 @@ function Socket (type, opts) {
 
     this.binding = nn.Socket(this.af_domain, this.protocol);
     this.queue = [];
+    this.channels = {};
 
     for(var sokopt in sol){
         if(opts.hasOwnProperty(sokopt)) this[sokopt](opts[sokopt]);
@@ -372,6 +373,28 @@ function opt (option) {
   }
 };
 
+/* chan and rmchan sockopt methods. only relevant for subscription sockets */
+Socket.prototype.chan       = function(){
+  var args = arguments;
+  var channels = args.length;
+  while(channels--) {
+    if (nn.Subchan(this.binding, args[channels]) == 0){
+      this.channels[args[channels]] = true;
+    }
+  };
+}
+
+Socket.prototype.rmchan     = function(){
+  var args = arguments;
+  var channels = args.length;
+  while(channels--) {
+    if (this.channels[args[channels]] &&
+      nn.Setopt(this.binding, nn.NN_SUB, nn.NN_SUB_UNSUBSCRIBE, args[channels]) == 0){
+        this.channels[args[channels]] = false;
+    }
+  };
+}
+
 /**
  * module API
  */