From 6c05fa11f65e810a4cd5d4c759bb2bf1978c3094 Mon Sep 17 00:00:00 2001
From: pidanooo <jingouli666@163.com>
Date: Thu, 8 Aug 2019 22:04:58 +0800
Subject: [PATCH] =?UTF-8?q?=E9=87=91=E9=91=AB-exercise17?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

金鑫-exercise17
---
 Observable.js | 20 ++++++++++++++++++++
 PubSub.js     | 11 +++++++++++
 2 files changed, 31 insertions(+)

diff --git a/Observable.js b/Observable.js
index 03545cd..d3e93ba 100644
--- a/Observable.js
+++ b/Observable.js
@@ -11,12 +11,23 @@ class ObserverList {
   }
   add(observer) {
     // todo add observer to list
+    return this.observerList.push(observer);
   }
   remove(observer) {
     // todo remove observer from list
+    const index=this.observerList.indexOf(observer);
+    if(index>-1){
+      return this.observerList.splice(index,1);
+    }
   }
   count() {
     // return observer list size
+    return this.observerList.length
+  }
+  get(index){
+    if(index>-1 && index<this.observerList.length){
+      return this.observerList[index]
+    }
   }
 }
 
@@ -26,12 +37,21 @@ class Subject {
   }
   addObserver(observer) {
     // todo add observer
+    this.observers.add(observer);
   }
   removeObserver(observer) {
     // todo remove observer
+    this.observers.remove(observer);
   }
   notify(...args) {
     // todo notify
+    const length=this.observers.count();
+    if(length>0){
+      for(let i=0;i<length;i++){
+        this.observers.get(i).update(...args)
+      }
+    }
+
   }
 }
 
diff --git a/PubSub.js b/PubSub.js
index 0c7999e..cd1be50 100644
--- a/PubSub.js
+++ b/PubSub.js
@@ -13,14 +13,25 @@ module.exports = class PubSub {
 
   subscribe(type, fn) {
     // todo subscribe
+    if(!this.subscribers[type]){
+      this.subscribers[type]=[];
+    }
+    this.subscribers[type].push(fn);
   }
 
   unsubscribe(type, fn) {
     // todo unsubscribe
+    delete this.subscribers[type]
   }
 
   publish(type, ...args) {
     // todo publish
+    if(!this.subscribers[type]){
+      return false
+    }
+    this.subscribers[type].forEach(fn=>{
+      fn(...args)
+    })
   }
 
 }