perf(count): fast-path for counting over scalars

ReactiveX · Oct 14, 2015 · c35a120 · c35a120
1 parent 86a9b45
commit c35a120
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/observables/ScalarObservable.ts b/src/observables/ScalarObservable.ts
@@ -89,4 +89,8 @@ export default class ScalarObservable<T> extends Observable<T> {
  scan<R>(project: (acc: R, x: T) => R, acc?: R): Observable<R> {
  return this.reduce(project, acc);
  }
+
+ count(): Observable<number> {
+ return new ScalarObservable(1);
+ }
 }