perf(reduce): add fast-path for reducing over scalar observables

ReactiveX · Oct 14, 2015 · 4c65136 · 4c65136
1 parent eb11736
commit 4c65136
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/src/observables/ScalarObservable.ts b/src/observables/ScalarObservable.ts
@@ -73,4 +73,16 @@ export default class ScalarObservable<T> extends Observable<T> {
       return new EmptyObservable();
     }
   }
+
+  reduce<R>(project: (acc: R, x: T) => R, acc?: R): Observable<R> {
+    if (typeof acc === 'undefined') {
+      return <any>this;
+    }
+    let result = tryCatch(project)(acc, this.value);
+    if (result === errorObject) {
+      return new ErrorObservable(errorObject.e);
+    } else {
+      return new ScalarObservable(result);
+    }
+  }
 }