test(count): add test for counting over scalars

ReactiveX · Oct 14, 2015 · 86a9b45 · 86a9b45
1 parent 559fd8a
commit 86a9b45
Showing 1 changed file with 18 additions and 0 deletions.
diff --git a/perf/micro/immediate-scheduler/operators/count-scalar.js b/perf/micro/immediate-scheduler/operators/count-scalar.js
@@ -0,0 +1,18 @@
+var RxOld = require('rx');
+var RxNew = require('../../../../index');
+
+module.exports = function (suite) {
+  var oldConcatWithImmediateScheduler = RxOld.Observable.just(25, RxOld.Scheduler.immediate).count();
+  var newConcatWithImmediateScheduler = RxNew.Observable.of(25).count();
+
+  function _next(x) { }
+  function _error(e) { }
+  function _complete() { }
+  return suite
+      .add('old count over scalar with immediate scheduler', function () {
+        oldConcatWithImmediateScheduler.subscribe(_next, _error, _complete);
+      })
+      .add('new count over scalar with immediate scheduler', function () {
+        newConcatWithImmediateScheduler.subscribe(_next, _error, _complete);
+      });
+};