test(filter): add micro perf tests for filtering scalar observables

ReactiveX · Oct 14, 2015 · e80bab6 · e80bab6
1 parent 7b0d3dc
commit e80bab6
Show file tree

Hide file tree

Showing 2 changed files with 50 additions and 0 deletions.
diff --git a/perf/micro/immediate-scheduler/operators/filter-scalar-false.js b/perf/micro/immediate-scheduler/operators/filter-scalar-false.js
@@ -0,0 +1,25 @@
+var RxOld = require('rx');
+var RxNew = require('../../../../index');
+
+module.exports = function (suite) {
+  function isEven(x) {
+    return x % 2 === 0;
+  }
+
+  function greaterThanTen(x) {
+    return x > 10;
+  }
+  var oldFilterWithImmediateScheduler = RxOld.Observable.just(45, RxOld.Scheduler.immediate).filter(greaterThanTen).filter(isEven);
+  var newFilterWithImmediateScheduler = RxNew.Observable.of(45).filter(greaterThanTen).filter(isEven);
+
+  function _next(x) { }
+  function _error(e) { }
+  function _complete() { }
+  return suite
+      .add('old filter over scalar in the negative with immediate scheduler', function () {
+        oldFilterWithImmediateScheduler.subscribe(_next, _error, _complete);
+      })
+      .add('new filter over scalar in the negative with immediate scheduler', function () {
+        newFilterWithImmediateScheduler.subscribe(_next, _error, _complete);
+      });
+};
diff --git a/perf/micro/immediate-scheduler/operators/filter-scalar-true.js b/perf/micro/immediate-scheduler/operators/filter-scalar-true.js
@@ -0,0 +1,25 @@
+var RxOld = require('rx');
+var RxNew = require('../../../../index');
+
+module.exports = function (suite) {
+  function isEven(x) {
+    return x % 2 === 0;
+  }
+
+  function greaterThanTen(x) {
+    return x > 10;
+  }
+  var oldFilterWithImmediateScheduler = RxOld.Observable.just(42, RxOld.Scheduler.immediate).filter(greaterThanTen).filter(isEven);
+  var newFilterWithImmediateScheduler = RxNew.Observable.of(42).filter(greaterThanTen).filter(isEven);
+
+  function _next(x) { }
+  function _error(e) { }
+  function _complete() { }
+  return suite
+      .add('old filter over scalar in the affirmative with immediate scheduler', function () {
+        oldFilterWithImmediateScheduler.subscribe(_next, _error, _complete);
+      })
+      .add('new filter over scalar in the affirmative with immediate scheduler', function () {
+        newFilterWithImmediateScheduler.subscribe(_next, _error, _complete);
+      });
+};