perf(operator): fix all operators to refer this.proxy initially to em…

…ptyObserver
staltz · Feb 26, 2016 · ad210fc · ad210fc
1 parent 57453f2
commit ad210fc
Show file tree

Hide file tree

Showing 6 changed files with 11 additions and 1 deletion.
diff --git a/src/operator/DebugMachine.ts b/src/operator/DebugMachine.ts
@@ -1,12 +1,14 @@
 import {Observer} from '../Observer';
 import {Machine} from '../Machine';
 import {Stream} from '../Stream';
+import {emptyObserver} from '../utils/emptyObserver';
 
 export class DebugMachine<T> implements Machine<T> {
   public proxy: Observer<T>;
 
   constructor(public spy: (t: T) => void = null,
               public inStream: Stream<T>) {
+    this.proxy = emptyObserver;
   }
 
   start(outStream: Stream<T>): void {

diff --git a/src/operator/FilterMachine.ts b/src/operator/FilterMachine.ts
@@ -1,12 +1,14 @@
 import {Observer} from '../Observer';
 import {Machine} from '../Machine';
 import {Stream} from '../Stream';
+import {emptyObserver} from '../utils/emptyObserver';
 
 export class FilterMachine<T> implements Machine<T> {
   public proxy: Observer<T>;
 
   constructor(public predicate: (t: T) => boolean,
               public inStream: Stream<T>) {
+    this.proxy = emptyObserver;
   }
 
   start(outStream: Stream<T>): void {

diff --git a/src/operator/FoldMachine.ts b/src/operator/FoldMachine.ts
@@ -18,7 +18,7 @@ export class FoldMachine<T, R> implements Machine<R> {
     outStream.next(this.initAcc);
     this.proxy = {
       next: (t: T) => {
-        this.acc = this.accumulator(this.acc, t)
+        this.acc = this.accumulator(this.acc, t);
         outStream.next(this.acc);
       },
       error: (err) => outStream.error(err),

diff --git a/src/operator/MapMachine.ts b/src/operator/MapMachine.ts
@@ -1,12 +1,14 @@
 import {Observer} from '../Observer';
 import {Machine} from '../Machine';
 import {Stream} from '../Stream';
+import {emptyObserver} from '../utils/emptyObserver';
 
 export class MapMachine<T, U> implements Machine<U> {
   public proxy: Observer<T>;
 
   constructor(public projection: (t: T) => U,
               public inStream: Stream<T>) {
+    this.proxy = emptyObserver;
   }
 
   start(outStream: Stream<U>): void {

diff --git a/src/operator/SkipMachine.ts b/src/operator/SkipMachine.ts
@@ -1,13 +1,15 @@
 import {Observer} from '../Observer';
 import {Machine} from '../Machine';
 import {Stream} from '../Stream';
+import {emptyObserver} from '../utils/emptyObserver';
 
 export class SkipMachine<T> implements Machine<T> {
   public proxy: Observer<T>;
   public skipped: number;
 
   constructor(public max: number,
               public inStream: Stream<T>) {
+    this.proxy = emptyObserver;
     this.skipped = 0;
   }
 

diff --git a/src/operator/TakeMachine.ts b/src/operator/TakeMachine.ts
@@ -1,13 +1,15 @@
 import {Observer} from '../Observer';
 import {Machine} from '../Machine';
 import {Stream} from '../Stream';
+import {emptyObserver} from '../utils/emptyObserver';
 
 export class TakeMachine<T> implements Machine<T> {
   public proxy: Observer<T>;
   public taken: number;
 
   constructor(public max: number,
               public inStream: Stream<T>) {
+    this.proxy = emptyObserver;
     this.taken = 0;
   }