|  | 
| 1 | 1 | interface Observer { | 
| 2 |  | - uniqueID: string; | 
| 3 |  | - update(): void; | 
|  | 2 | + uniqueID: string; | 
|  | 3 | + update(): void; | 
|  | 4 | +} | 
|  | 5 | + | 
|  | 6 | +class ConcreteObserver implements Observer { | 
|  | 7 | + public uniqueID: string | 
|  | 8 | + constructor(uniqueID: string) { | 
|  | 9 | + this.uniqueID = uniqueID; | 
| 4 | 10 |  } | 
| 5 |  | -  | 
| 6 |  | - class ConcreteObserver implements Observer { | 
| 7 |  | - public uniqueID: string | 
| 8 |  | - constructor(uniqueID: string) { | 
| 9 |  | - this.uniqueID = uniqueID; | 
| 10 |  | - } | 
| 11 |  | -  | 
| 12 |  | - update(): void { | 
| 13 |  | - console.log(`${this.uniqueID} updates something...`); | 
| 14 |  | - } | 
|  | 11 | + | 
|  | 12 | + update(): void { | 
|  | 13 | + console.log(`${this.uniqueID} updates something...`); | 
| 15 | 14 |  } | 
| 16 |  | -  | 
| 17 |  | - function findObserver(obs: Observer[], uniqueID: string) { | 
| 18 |  | - let index = 0; | 
| 19 |  | - const existed = obs.some((observer, idx) => { | 
| 20 |  | - index = idx; | 
| 21 |  | - return observer.uniqueID === uniqueID; | 
| 22 |  | - }); | 
| 23 |  | - return { | 
| 24 |  | - existed, | 
| 25 |  | - index | 
| 26 |  | - }; | 
|  | 15 | +} | 
|  | 16 | + | 
|  | 17 | +function findObserver(obs: Observer[], uniqueID: string) { | 
|  | 18 | + let index = 0; | 
|  | 19 | + const existed = obs.some((observer, idx) => { | 
|  | 20 | + index = idx; | 
|  | 21 | + return observer.uniqueID === uniqueID; | 
|  | 22 | + }); | 
|  | 23 | + return { | 
|  | 24 | + existed, | 
|  | 25 | + index | 
|  | 26 | + }; | 
|  | 27 | +} | 
|  | 28 | + | 
|  | 29 | +class Subject { | 
|  | 30 | + private _observers: Observer[]; | 
|  | 31 | + constructor() { | 
|  | 32 | + this._observers = []; | 
| 27 | 33 |  } | 
| 28 |  | -  | 
| 29 |  | - class Subject { | 
| 30 |  | - private _observers: Observer[]; | 
| 31 |  | - constructor() { | 
| 32 |  | - this._observers = []; | 
|  | 34 | + | 
|  | 35 | + registerObserver(ob: Observer) { | 
|  | 36 | + const id: string = ob.uniqueID; | 
|  | 37 | + if (findObserver(this._observers, id).existed) { | 
|  | 38 | + return console.log(`Observer ${id} is already in list`); | 
| 33 | 39 |  } | 
| 34 |  | -  | 
| 35 |  | - registerObserver(ob: Observer) { | 
| 36 |  | - const id: string = ob.uniqueID; | 
| 37 |  | - if (findObserver(this._observers, id).existed) { | 
| 38 |  | - return console.log(`Observer ${id} is already in list`); | 
| 39 |  | - } | 
| 40 |  | - this._observers.push(ob); | 
| 41 |  | - console.log(`Observer ${ob.uniqueID} is pushed into list`); | 
| 42 |  | - console.log(this._observers); | 
| 43 |  | - } | 
| 44 |  | -  | 
| 45 |  | - removeObserver(uniqueID: string) { | 
| 46 |  | - const { existed, index } = findObserver(this._observers, uniqueID); | 
| 47 |  | - if (existed) { | 
| 48 |  | - this._observers.splice(index, 1); | 
| 49 |  | - console.log(`Observer ${uniqueID} is removed from list`); | 
| 50 |  | - } else { | 
| 51 |  | - console.log('Observer not existed'); | 
| 52 |  | - } | 
| 53 |  | - } | 
| 54 |  | -  | 
| 55 |  | - notifyObservers() { | 
| 56 |  | - console.log('Subject notify all observers >>'); | 
| 57 |  | - this._observers.map((observer) => { | 
| 58 |  | - observer.update(); | 
| 59 |  | - }); | 
|  | 40 | + this._observers.push(ob); | 
|  | 41 | + console.log(`Observer ${ob.uniqueID} is pushed into list`); | 
|  | 42 | + console.log(this._observers); | 
|  | 43 | + } | 
|  | 44 | + | 
|  | 45 | + removeObserver(uniqueID: string) { | 
|  | 46 | + const { existed, index } = findObserver(this._observers, uniqueID); | 
|  | 47 | + if (existed) { | 
|  | 48 | + this._observers.splice(index, 1); | 
|  | 49 | + console.log(`Observer ${uniqueID} is removed from list`); | 
|  | 50 | + } else { | 
|  | 51 | + console.log('Observer not existed'); | 
| 60 | 52 |  } | 
| 61 | 53 |  } | 
|  | 54 | + | 
|  | 55 | + notifyObservers() { | 
|  | 56 | + console.log('Subject notify all observers >>'); | 
|  | 57 | + this._observers.map((observer) => { | 
|  | 58 | + observer.update(); | 
|  | 59 | + }); | 
|  | 60 | + } | 
|  | 61 | +} | 
| 62 | 62 | 
 | 
| 63 | 63 | // USAGE: | 
| 64 |  | - const subject = new Subject(); | 
| 65 |  | -  | 
| 66 |  | - const obA = new ConcreteObserver('A'); | 
| 67 |  | - const obB = new ConcreteObserver('B'); | 
| 68 |  | - const obC = new ConcreteObserver('C'); | 
| 69 |  | -  | 
| 70 |  | - subject.registerObserver(obA); | 
| 71 |  | - subject.registerObserver(obA); // already existed | 
| 72 |  | -  | 
| 73 |  | - subject.registerObserver(obB); | 
| 74 |  | - subject.registerObserver(obC); | 
| 75 |  | -  | 
| 76 |  | - subject.notifyObservers(); | 
|  | 64 | +const subject = new Subject(); | 
|  | 65 | + | 
|  | 66 | +const obA = new ConcreteObserver('A'); | 
|  | 67 | +const obB = new ConcreteObserver('B'); | 
|  | 68 | +const obC = new ConcreteObserver('C'); | 
|  | 69 | + | 
|  | 70 | +subject.registerObserver(obA); | 
|  | 71 | +subject.registerObserver(obA); // already existed | 
|  | 72 | + | 
|  | 73 | +subject.registerObserver(obB); | 
|  | 74 | +subject.registerObserver(obC); | 
|  | 75 | + | 
|  | 76 | +subject.notifyObservers(); | 
| 77 | 77 | // OUTPUT: | 
| 78 | 78 | // "Observer A is pushed into list" | 
| 79 | 79 | // "Observer A is already in list" | 
|  | 
0 commit comments