chore(publish): add micro perf tests for publish

kwonoj · May 2, 2016 · 0f8bf28 · 0f8bf28
1 parent 238c187
commit 0f8bf28
Show file tree

Hide file tree

Showing 2 changed files with 46 additions and 0 deletions.
diff --git a/perf/micro/immediate-scheduler/operators/publish-selector.js b/perf/micro/immediate-scheduler/operators/publish-selector.js
@@ -0,0 +1,24 @@
+var RxOld = require('rx');
+var RxNew = require('../../../../index');
+
+module.exports = function (suite) {
+ var oldPublishWithImmediateScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.immediate)
+ .publish(function (x) {
+ return x;
+ });
+ var newPublishWithImmediateScheduler = RxNew.Observable.range(0, 25)
+ .publish(function (x) {
+ return x;
+ });
+
+ function _next(x) { }
+ function _error(e) { }
+ function _complete() { }
+ return suite
+ .add('old publish with selector and immediate scheduler', function () {
+ oldPublishWithImmediateScheduler.subscribe(_next, _error, _complete);
+ })
+ .add('new publish with selector and immediate scheduler', function () {
+ newPublishWithImmediateScheduler.subscribe(_next, _error, _complete);
+ });
+};
diff --git a/perf/micro/immediate-scheduler/operators/publish.js b/perf/micro/immediate-scheduler/operators/publish.js
@@ -0,0 +1,22 @@
+var RxOld = require('rx');
+var RxNew = require('../../../../index');
+
+module.exports = function (suite) {
+ var oldPublishWithImmediateScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.immediate).publish();
+ var newPublishWithImmediateScheduler = RxNew.Observable.range(0, 25).publish();
+
+ function _next(x) { }
+ function _error(e) { }
+ function _complete() { }
+
+ oldPublishWithImmediateScheduler.connect();
+ newPublishWithImmediateScheduler.connect();
+
+ return suite
+ .add('old publish with immediate scheduler', function () {
+ oldPublishWithImmediateScheduler.subscribe(_next, _error, _complete);
+ })
+ .add('new publish with immediate scheduler', function () {
+ newPublishWithImmediateScheduler.subscribe(_next, _error, _complete);
+ });
+};