Add publisher.clear() to clear the subscribers. Remove some duplicated codes

Author: johnteee

monadio.js

@@ -9,28 +9,16 @@ class MonadIODef {
       return fn(self.effect());
     });
   }
-  bind(fn) {
-    return this.then(fn);
-  }
-  map(fn) {
-    return this.then(fn);
-  }
   flatMap(fn) {
     return this.then((result)=>fn(result).effect());
   }
   of(ref) {
     var m = new MonadIODef(()=>ref);
     return m;
   }
-  just(ref) {
-    return this.of(ref);
-  }
   ap(fnM) {
     return fnM.chain(f => this.map(f));
   }
-  chain(fn) {
-    return this.flatMap(fn);
-  }
 
   subscribe(fn, asynchronized) {
     if (asynchronized) {
@@ -41,6 +29,10 @@ class MonadIODef {
     return fn;
   }
 }
+MonadIODef.prototype.just = MonadIODef.prototype.of
+MonadIODef.prototype.chain = MonadIODef.prototype.flatMap
+MonadIODef.prototype.bind = MonadIODef.prototype.then
+MonadIODef.prototype.map = MonadIODef.prototype.then
 
 var MonadIO = new MonadIODef({});
 MonadIO.fromPromise = function (p) {

publisher.js

@@ -23,6 +23,9 @@ class Publisher {
   unsubscribe(fn) {
     this.subscribers = this.subscribers.filter((item)=>item!==fn);
   }
+  clear() {
+    this.subscribers = []
+  }
   publish(result,asynchronized) {
     this.subscribers.forEach((fn)=>asynchronized ? Promise.resolve(result).then(fn) : fn(result));
   }

test/publisher.js

@@ -7,8 +7,12 @@ describe('Publisher', function () {
 
       v = 0;
       p.subscribe((i)=>v=i);
-      p.publish(1);
 
+      p.publish(1);
+      v.should.equal(1)
+      // Clear
+      p.clear()
+      p.publish(2);
       v.should.equal(1)
 	});
   it('async', function (done) {