From 10137544e2cadb9f890e3a702eaa0e45962c3b83 Mon Sep 17 00:00:00 2001 From: benlesh Date: Fri, 30 Mar 2018 16:20:06 -0700 Subject: [PATCH] fix(lint_perf): fix lint issues with newer perf tests --- .../subject/replaysubject.js | 16 ++++++++-------- .../subject/replaysubject_windowtime.js | 16 ++++++++-------- .../immediate-scheduler/operators/buffertime.js | 16 +++++++++------- .../immediate-scheduler/subject/replaysubject.js | 16 ++++++++-------- .../subject/replaysubject_windowtime.js | 16 ++++++++-------- 5 files changed, 41 insertions(+), 39 deletions(-) diff --git a/perf/micro/current-thread-scheduler/subject/replaysubject.js b/perf/micro/current-thread-scheduler/subject/replaysubject.js index 3a5e88fcd9..22d350bea8 100644 --- a/perf/micro/current-thread-scheduler/subject/replaysubject.js +++ b/perf/micro/current-thread-scheduler/subject/replaysubject.js @@ -6,12 +6,12 @@ module.exports = function (suite) { var newRangeWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue); return suite - .add('old ReplaySubject with immediate scheduler', function () { - var subject = new RxOld.ReplaySubject(5, Number.POSITIVE_INFINITY, RxOld.Scheduler.currentThread); - oldRangeWithCurrentThreadScheduler.subscribe(subject); - }) - .add('new ReplaySubject with immediate scheduler', function () { - var subject = new RxNew.ReplaySubject(5, Number.POSITIVE_INFINITY, RxNew.Scheduler.queue); - newRangeWithCurrentThreadScheduler.subscribe(subject); - }); + .add('old ReplaySubject with immediate scheduler', function () { + var subject = new RxOld.ReplaySubject(5, Number.POSITIVE_INFINITY, RxOld.Scheduler.currentThread); + oldRangeWithCurrentThreadScheduler.subscribe(subject); + }) + .add('new ReplaySubject with immediate scheduler', function () { + var subject = new RxNew.ReplaySubject(5, Number.POSITIVE_INFINITY, RxNew.Scheduler.queue); + newRangeWithCurrentThreadScheduler.subscribe(subject); + }); }; \ No newline at end of file diff --git a/perf/micro/current-thread-scheduler/subject/replaysubject_windowtime.js b/perf/micro/current-thread-scheduler/subject/replaysubject_windowtime.js index a338502aef..4b718c5c05 100644 --- a/perf/micro/current-thread-scheduler/subject/replaysubject_windowtime.js +++ b/perf/micro/current-thread-scheduler/subject/replaysubject_windowtime.js @@ -6,12 +6,12 @@ module.exports = function (suite) { var newRangeWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue); return suite - .add('old ReplaySubject with immediate scheduler', function () { - var subject = new RxOld.ReplaySubject(5, 50, RxOld.Scheduler.currentThread); - oldRangeWithCurrentThreadScheduler.subscribe(subject); - }) - .add('new ReplaySubject with immediate scheduler', function () { - var subject = new RxNew.ReplaySubject(5, 50, RxNew.Scheduler.queue); - newRangeWithCurrentThreadScheduler.subscribe(subject); - }); + .add('old ReplaySubject with immediate scheduler', function () { + var subject = new RxOld.ReplaySubject(5, 50, RxOld.Scheduler.currentThread); + oldRangeWithCurrentThreadScheduler.subscribe(subject); + }) + .add('new ReplaySubject with immediate scheduler', function () { + var subject = new RxNew.ReplaySubject(5, 50, RxNew.Scheduler.queue); + newRangeWithCurrentThreadScheduler.subscribe(subject); + }); }; \ No newline at end of file diff --git a/perf/micro/immediate-scheduler/operators/buffertime.js b/perf/micro/immediate-scheduler/operators/buffertime.js index 584cc58798..ec86b6fdd5 100644 --- a/perf/micro/immediate-scheduler/operators/buffertime.js +++ b/perf/micro/immediate-scheduler/operators/buffertime.js @@ -2,17 +2,19 @@ var RxOld = require('rx'); var RxNew = require('../../../../index'); module.exports = function (suite) { - var oldBufferWithImmediateScheduler = RxOld.Observable.interval(25, RxOld.Scheduler.immediate).bufferWithTime(60, RxOld.Scheduler.immediate).take(3); + var oldBufferWithImmediateScheduler = + RxOld.Observable.interval(25, RxOld.Scheduler.immediate) + .bufferWithTime(60, RxOld.Scheduler.immediate).take(3); var newBufferWithImmediateScheduler = RxNew.Observable.interval(25).bufferTime(60).take(3); function _next(x) { } function _error(e) { } function _complete() { } return suite - .add('old bufferTime() with immediate scheduler', function () { - oldBufferWithImmediateScheduler.subscribe(_next, _error, _complete); - }) - .add('new bufferTime() with immediate scheduler', function () { - newBufferWithImmediateScheduler.subscribe(_next, _error, _complete); - }); + .add('old bufferTime() with immediate scheduler', function () { + oldBufferWithImmediateScheduler.subscribe(_next, _error, _complete); + }) + .add('new bufferTime() with immediate scheduler', function () { + newBufferWithImmediateScheduler.subscribe(_next, _error, _complete); + }); }; \ No newline at end of file diff --git a/perf/micro/immediate-scheduler/subject/replaysubject.js b/perf/micro/immediate-scheduler/subject/replaysubject.js index 0da0bdbb9d..902bf340ad 100644 --- a/perf/micro/immediate-scheduler/subject/replaysubject.js +++ b/perf/micro/immediate-scheduler/subject/replaysubject.js @@ -6,12 +6,12 @@ module.exports = function (suite) { var newRangeWithImmediateScheduler = RxNew.Observable.range(0, 25); return suite - .add('old ReplaySubject with immediate scheduler', function () { - var subject = new RxOld.ReplaySubject(5, Number.POSITIVE_INFINITY, RxOld.Scheduler.immediate); - oldRangeWithImmediateScheduler.subscribe(subject); - }) - .add('new ReplaySubject with immediate scheduler', function () { - var subject = new RxNew.ReplaySubject(5, Number.POSITIVE_INFINITY); - newRangeWithImmediateScheduler.subscribe(subject); - }); + .add('old ReplaySubject with immediate scheduler', function () { + var subject = new RxOld.ReplaySubject(5, Number.POSITIVE_INFINITY, RxOld.Scheduler.immediate); + oldRangeWithImmediateScheduler.subscribe(subject); + }) + .add('new ReplaySubject with immediate scheduler', function () { + var subject = new RxNew.ReplaySubject(5, Number.POSITIVE_INFINITY); + newRangeWithImmediateScheduler.subscribe(subject); + }); }; \ No newline at end of file diff --git a/perf/micro/immediate-scheduler/subject/replaysubject_windowtime.js b/perf/micro/immediate-scheduler/subject/replaysubject_windowtime.js index 98e5291c01..9445cb0667 100644 --- a/perf/micro/immediate-scheduler/subject/replaysubject_windowtime.js +++ b/perf/micro/immediate-scheduler/subject/replaysubject_windowtime.js @@ -6,12 +6,12 @@ module.exports = function (suite) { var newRangeWithImmediateScheduler = RxNew.Observable.range(0, 25); return suite - .add('old ReplaySubject with immediate scheduler', function () { - var subject = new RxOld.ReplaySubject(5, 50, RxOld.Scheduler.immediate); - oldRangeWithImmediateScheduler.subscribe(subject); - }) - .add('new ReplaySubject with immediate scheduler', function () { - var subject = new RxNew.ReplaySubject(5, 50); - newRangeWithImmediateScheduler.subscribe(subject); - }); + .add('old ReplaySubject with immediate scheduler', function () { + var subject = new RxOld.ReplaySubject(5, 50, RxOld.Scheduler.immediate); + oldRangeWithImmediateScheduler.subscribe(subject); + }) + .add('new ReplaySubject with immediate scheduler', function () { + var subject = new RxNew.ReplaySubject(5, 50); + newRangeWithImmediateScheduler.subscribe(subject); + }); }; \ No newline at end of file