fix(mergeAll): fix mergeAll micro performance tests to use mapTo inst…

…ead of map.
ReactiveX · Oct 15, 2015 · 616e86e · 616e86e
1 parent 6af8f2d
commit 616e86e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/perf/micro/current-thread-scheduler/operators/mergeall.js b/perf/micro/current-thread-scheduler/operators/mergeall.js
@@ -6,7 +6,7 @@ module.exports = function (suite) {
     .map(RxOld.Observable.range(0, 25), RxOld.Scheduler.currentThread)
     .mergeAll();
   var newMergeAllWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate)
-    .map(RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate))
+    .mapTo(RxNew.Observable.range(0, 25, RxNew.Scheduler.immediate))
     .mergeAll();
 
   function _next(x) { }
@@ -19,4 +19,4 @@ module.exports = function (suite) {
     .add('new mergeAll with current thread scheduler', function () {
       newMergeAllWithCurrentThreadScheduler.subscribe(_next, _error, _complete);
     });
-};
+};
diff --git a/perf/micro/immediate-scheduler/operators/mergeall.js b/perf/micro/immediate-scheduler/operators/mergeall.js
@@ -6,7 +6,7 @@ module.exports = function (suite) {
     .map(RxOld.Observable.range(0, 25), RxOld.Scheduler.immediate)
     .mergeAll();
   var newMergeAllWithImmediateScheduler = RxNew.Observable.range(0, 25)
-    .map(RxNew.Observable.range(0, 25))
+    .mapTo(RxNew.Observable.range(0, 25))
     .mergeAll();
 
   function _next(x) { }
@@ -19,4 +19,4 @@ module.exports = function (suite) {
     .add('new mergeAll with immediate scheduler', function () {
       newMergeAllWithImmediateScheduler.subscribe(_next, _error, _complete);
     });
-};
+};