diff --git a/perf/micro/immediate-scheduler/operators/skipuntil.js b/perf/micro/immediate-scheduler/operators/skipuntil.js index eddcda4d76..2d29b62e23 100644 --- a/perf/micro/immediate-scheduler/operators/skipuntil.js +++ b/perf/micro/immediate-scheduler/operators/skipuntil.js @@ -11,10 +11,10 @@ module.exports = function (suite) { function _error(e) { } function _complete() { } return suite - .add('old skip with immediate scheduler', function () { + .add('old skipUntil with immediate scheduler', function () { oldSkipUntilWithImmediateScheduler.subscribe(_next, _error, _complete); }) - .add('new skip with immediate scheduler', function () { + .add('new skipUntil with immediate scheduler', function () { newSkipUntilWithImmediateScheduler.subscribe(_next, _error, _complete); }); -}; \ No newline at end of file +}; diff --git a/perf/micro/immediate-scheduler/operators/takeuntil.js b/perf/micro/immediate-scheduler/operators/takeuntil.js new file mode 100644 index 0000000000..0d67a1051c --- /dev/null +++ b/perf/micro/immediate-scheduler/operators/takeuntil.js @@ -0,0 +1,20 @@ +var RxOld = require('rx'); +var RxNew = require('../../../../index'); + +module.exports = function (suite) { + var oldTakeUntilWithImmediateScheduler = RxOld.Observable.interval(25, RxOld.Scheduler.immediate) + .take(3).takeUntil(RxOld.Observable.timer(60, RxOld.Scheduler.immediate)); + var newTakeUntilWithImmediateScheduler = RxNew.Observable.interval(25) + .take(3).takeUntil(RxNew.Observable.timer(60)); + + function _next(x) { } + function _error(e) { } + function _complete() { } + return suite + .add('old takeUntil with immediate scheduler', function () { + oldTakeUntilWithImmediateScheduler.subscribe(_next, _error, _complete); + }) + .add('new takeUntil with immediate scheduler', function () { + newTakeUntilWithImmediateScheduler.subscribe(_next, _error, _complete); + }); +}; \ No newline at end of file