chore(test): add micro-benchmark performance test for startwith operator

ReactiveX · Sep 3, 2015 · 2028a61 · 2028a61
1 parent 492f594
commit 2028a61
Show file tree

Hide file tree

Showing 3 changed files with 42 additions and 0 deletions.
diff --git a/perf/micro/current-thread-scheduler/operators/start-with.js b/perf/micro/current-thread-scheduler/operators/start-with.js
@@ -0,0 +1,20 @@
+var RxOld = require("rx");
+var RxNew = require("../../../../index");
+
+module.exports = function (suite) {
+
+    var oldStartWithWithCurrentThreadScheduler = RxOld.Observable.of(25, RxOld.Scheduler.currentThread).startWith(5, RxOld.Scheduler.currentThread);
+    var newStartWithWithCurrentThreadScheduler = RxNew.Observable.of(25, RxNew.Scheduler.immediate).startWith(5, RxNew.Scheduler.immediate);
+
+    return suite
+        .add('old startWith with current thread scheduler', function () {
+            oldStartWithWithCurrentThreadScheduler.subscribe(_next, _error, _complete);
+        })
+        .add('new startWith with current thread scheduler', function () {
+            newStartWithWithCurrentThreadScheduler.subscribe(_next, _error, _complete);
+        });
+
+    function _next(x) { }
+    function _error(e){ }
+    function _complete(){ }
+};
diff --git a/perf/micro/immediate-scheduler/operators/start-with.js b/perf/micro/immediate-scheduler/operators/start-with.js
@@ -0,0 +1,20 @@
+var RxOld = require("rx");
+var RxNew = require("../../../../index");
+
+module.exports = function (suite) {
+
+    var oldStartWithWithImmediateScheduler = RxOld.Observable.of(25, RxOld.Scheduler.immediate).startWith(5, RxOld.Scheduler.immediate);
+    var newStartWithWithImmediateScheduler = RxNew.Observable.of(25).startWith(5);
+
+    return suite
+        .add('old startWith with immediate scheduler', function () {
+            oldStartWithWithImmediateScheduler.subscribe(_next, _error, _complete);
+        })
+        .add('new startWith with immediate scheduler', function () {
+            newStartWithWithImmediateScheduler.subscribe(_next, _error, _complete);
+        });
+
+    function _next(x) { }
+    function _error(e){ }
+    function _complete(){ }
+};
diff --git a/perf/micro/index.js b/perf/micro/index.js
@@ -31,6 +31,7 @@ Observable.from([
         require("./immediate-scheduler/operators/map"),
         require("./immediate-scheduler/operators/scan"),
         require("./immediate-scheduler/operators/skip"),
+        require("./immediate-scheduler/operators/start-with"),
         require("./immediate-scheduler/operators/take"),
         require("./immediate-scheduler/operators/to-array"),
         require("./immediate-scheduler/operators/zip"),
@@ -61,6 +62,7 @@ Observable.from([
         require("./current-thread-scheduler/operators/map"),
         require("./current-thread-scheduler/operators/scan"),
         require("./current-thread-scheduler/operators/skip"),
+        require("./current-thread-scheduler/operators/start-with"),
         require("./current-thread-scheduler/operators/take"),
         require("./current-thread-scheduler/operators/to-array"),
         require("./current-thread-scheduler/operators/zip"),