HowProgrammingWorks
diff --git a/‎JavaScript/1-function.js
Copy file name to clipboardExpand all lines: JavaScript/1-function.js
+4-3Lines changed: 4 additions & 3 deletions b/‎JavaScript/1-function.js
Copy file name to clipboardExpand all lines: JavaScript/1-function.js
+4-3Lines changed: 4 additions & 3 deletions
diff --git a/‎JavaScript/2-class.js
Copy file name to clipboardExpand all lines: JavaScript/2-class.js
+9-9Lines changed: 9 additions & 9 deletions b/‎JavaScript/2-class.js
Copy file name to clipboardExpand all lines: JavaScript/2-class.js
+9-9Lines changed: 9 additions & 9 deletions
@@ -5,11 +5,10 @@ const randomChar = () => String
 
 const subscribe = observer => {
   const observable = { observer };
-  const timer = setInterval(() => {
+  setInterval(() => {
     const char = randomChar();
     observer(char);
   }, 200);
-  observable.complete = () => clearInterval(timer);
   return observable;
 };
 
@@ -22,7 +21,9 @@ function observer(char) {
   process.stdout.write(char);
   count++;
   if (count > 50) {
-    observable.complete();
     process.stdout.write('\n');
+    process.exit(0);
   }
 }
+
+console.dir({ observer, observable });
@@ -5,19 +5,17 @@ const randomChar = () => String
 
 class Observable {
   constructor() {
-    this.timer = setInterval(() => {
-      if (!this.onData) return;
+    this.observer = null;
+    setInterval(() => {
+      if (!this.observer) return;
       const char = randomChar();
-      this.onData(char);
+      this.observer(char);
     }, 200);
   }
-  subscribe(onData) {
-    this.onData = onData;
+  subscribe(observer) {
+    this.observer = observer;
     return this;
   }
-  complete() {
-    clearInterval(this.timer);
-  }
 }
 
 // Usage
@@ -30,7 +28,9 @@ function observer(char) {
   process.stdout.write(char);
   count++;
   if (count > 50) {
-    observable.complete();
     process.stdout.write('\n');
+    process.exit(0);
   }
 }
+
+console.dir({ observer, observable });