perf(Stream): remove this.num in Stream to improve perf

staltz · Feb 27, 2016 · 53bcaad · 53bcaad
1 parent 13bd699
commit 53bcaad
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/src/Stream.ts b/src/Stream.ts
@@ -10,11 +10,9 @@ import {LastProducer} from './operator/LastProducer';
 
 export class Stream<T> implements Observer<T> {
   public observers: Array<Observer<T>>;
-  public num: number; // Number of non-operator subscribers
 
   constructor(public machine: Producer<T>) {
     this.observers = [];
-    this.num = 0;
   }
 
   next(x: T): void {
@@ -52,14 +50,14 @@ export class Stream<T> implements Observer<T> {
 
   subscribe(observer: Observer<T>): void {
     this.observers.push(observer);
-    if (++this.num === 1) this.machine.start(this);
+    if (this.observers.length === 1) this.machine.start(this);
   }
 
   unsubscribe(observer: Observer<T>): void {
     const i = this.observers.indexOf(observer);
     if (i > -1) {
       this.observers.splice(i, 1);
-      if (--this.num <= 0) this.machine.stop();
+      if (this.observers.length <= 0) this.machine.stop();
     }
   }