perf(take): add fast-path for take over scalars

ReactiveX · Oct 14, 2015 · 33053b1 · 33053b1
1 parent be61d52
commit 33053b1
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/observables/ScalarObservable.ts b/src/observables/ScalarObservable.ts
@@ -100,4 +100,11 @@ export default class ScalarObservable<T> extends Observable<T> {
     }
     return this;
   }
+
+  take(count: number): Observable<T> {
+    if (count > 0) {
+      return this;
+    }
+    return new EmptyObservable();
+  }
 }