fix(micro-perf): use the correnct scheduler on current-thread tests

ReactiveX · Dec 14, 2015 · 3dff5eb · 3dff5eb
1 parent fe56b28
commit 3dff5eb
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/perf/micro/current-thread-scheduler/operators/buffercount.js b/perf/micro/current-thread-scheduler/operators/buffercount.js
@@ -3,7 +3,7 @@ var RxNew = require('../../../../index');
 
 module.exports = function (suite) {
   var oldBufferCountWithCurrentThreadScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.currentThread).bufferWithCount(5);
-  var newBufferCountWithCurrentThreadScheduler = RxNew.Observable.range(0, 25).bufferCount(5);
+  var newBufferCountWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue).bufferCount(5);
 
   function _next(x) { }
   function _error(e) { }

diff --git a/perf/micro/current-thread-scheduler/operators/concat.js b/perf/micro/current-thread-scheduler/operators/concat.js
@@ -4,8 +4,8 @@ var RxNew = require('../../../../index');
 module.exports = function (suite) {
   var oldConcatWithCurrentThreadScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.currentThread)
     .concat(RxOld.Observable.range(0, 25, RxOld.Scheduler.currentThread));
-  var newConcatWithCurrentThreadScheduler = RxNew.Observable.range(0, 25)
-    .concat(RxNew.Observable.range(0, 25));
+  var newConcatWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue)
+    .concat(RxNew.Observable.range(0, 25, RxNew.Scheduler.queue));
 
   function _next(x) { }
   function _error(e) { }

diff --git a/perf/micro/current-thread-scheduler/operators/windowcount.js b/perf/micro/current-thread-scheduler/operators/windowcount.js
@@ -3,7 +3,7 @@ var RxNew = require('../../../../index');
 
 module.exports = function (suite) {
   var oldWindowCountWithCurrentThreadScheduler = RxOld.Observable.range(0, 25, RxOld.Scheduler.currentThread).windowWithCount(5);
-  var newWindowCountWithCurrentThreadScheduler = RxNew.Observable.range(0, 25).windowCount(5);
+  var newWindowCountWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue).windowCount(5);
 
   function _next(x) { }
   function _error(e) { }