From 3dff5eb89de74101bcf6111bb524cef6dbe1cc14 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lu=C3=ADs=20Gabriel=20Lima?= Date: Mon, 14 Dec 2015 16:35:44 -0300 Subject: [PATCH] fix(micro-perf): use the correnct scheduler on current-thread tests --- perf/micro/current-thread-scheduler/operators/buffercount.js | 2 +- perf/micro/current-thread-scheduler/operators/concat.js | 4 ++-- perf/micro/current-thread-scheduler/operators/windowcount.js | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/perf/micro/current-thread-scheduler/operators/buffercount.js b/perf/micro/current-thread-scheduler/operators/buffercount.js index d73f46da86..2c54248fdb 100644 --- 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 index abfc1d8b15..4e6a83d05e 100644 --- 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 index 171cd4f14f..039f8a82e6 100644 --- 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) { }