Skip to content

Commit 1013754

Browse files
committed
fix(lint_perf): fix lint issues with newer perf tests
1 parent 55296c9 commit 1013754

File tree

5 files changed

+41
-39
lines changed

5 files changed

+41
-39
lines changed

perf/micro/current-thread-scheduler/subject/replaysubject.js

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,12 @@ module.exports = function (suite) {
66
var newRangeWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue);
77

88
return suite
9-
.add('old ReplaySubject with immediate scheduler', function () {
10-
var subject = new RxOld.ReplaySubject(5, Number.POSITIVE_INFINITY, RxOld.Scheduler.currentThread);
11-
oldRangeWithCurrentThreadScheduler.subscribe(subject);
12-
})
13-
.add('new ReplaySubject with immediate scheduler', function () {
14-
var subject = new RxNew.ReplaySubject(5, Number.POSITIVE_INFINITY, RxNew.Scheduler.queue);
15-
newRangeWithCurrentThreadScheduler.subscribe(subject);
16-
});
9+
.add('old ReplaySubject with immediate scheduler', function () {
10+
var subject = new RxOld.ReplaySubject(5, Number.POSITIVE_INFINITY, RxOld.Scheduler.currentThread);
11+
oldRangeWithCurrentThreadScheduler.subscribe(subject);
12+
})
13+
.add('new ReplaySubject with immediate scheduler', function () {
14+
var subject = new RxNew.ReplaySubject(5, Number.POSITIVE_INFINITY, RxNew.Scheduler.queue);
15+
newRangeWithCurrentThreadScheduler.subscribe(subject);
16+
});
1717
};

perf/micro/current-thread-scheduler/subject/replaysubject_windowtime.js

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,12 @@ module.exports = function (suite) {
66
var newRangeWithCurrentThreadScheduler = RxNew.Observable.range(0, 25, RxNew.Scheduler.queue);
77

88
return suite
9-
.add('old ReplaySubject with immediate scheduler', function () {
10-
var subject = new RxOld.ReplaySubject(5, 50, RxOld.Scheduler.currentThread);
11-
oldRangeWithCurrentThreadScheduler.subscribe(subject);
12-
})
13-
.add('new ReplaySubject with immediate scheduler', function () {
14-
var subject = new RxNew.ReplaySubject(5, 50, RxNew.Scheduler.queue);
15-
newRangeWithCurrentThreadScheduler.subscribe(subject);
16-
});
9+
.add('old ReplaySubject with immediate scheduler', function () {
10+
var subject = new RxOld.ReplaySubject(5, 50, RxOld.Scheduler.currentThread);
11+
oldRangeWithCurrentThreadScheduler.subscribe(subject);
12+
})
13+
.add('new ReplaySubject with immediate scheduler', function () {
14+
var subject = new RxNew.ReplaySubject(5, 50, RxNew.Scheduler.queue);
15+
newRangeWithCurrentThreadScheduler.subscribe(subject);
16+
});
1717
};

perf/micro/immediate-scheduler/operators/buffertime.js

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -2,17 +2,19 @@ var RxOld = require('rx');
22
var RxNew = require('../../../../index');
33

44
module.exports = function (suite) {
5-
var oldBufferWithImmediateScheduler = RxOld.Observable.interval(25, RxOld.Scheduler.immediate).bufferWithTime(60, RxOld.Scheduler.immediate).take(3);
5+
var oldBufferWithImmediateScheduler =
6+
RxOld.Observable.interval(25, RxOld.Scheduler.immediate)
7+
.bufferWithTime(60, RxOld.Scheduler.immediate).take(3);
68
var newBufferWithImmediateScheduler = RxNew.Observable.interval(25).bufferTime(60).take(3);
79

810
function _next(x) { }
911
function _error(e) { }
1012
function _complete() { }
1113
return suite
12-
.add('old bufferTime() with immediate scheduler', function () {
13-
oldBufferWithImmediateScheduler.subscribe(_next, _error, _complete);
14-
})
15-
.add('new bufferTime() with immediate scheduler', function () {
16-
newBufferWithImmediateScheduler.subscribe(_next, _error, _complete);
17-
});
14+
.add('old bufferTime() with immediate scheduler', function () {
15+
oldBufferWithImmediateScheduler.subscribe(_next, _error, _complete);
16+
})
17+
.add('new bufferTime() with immediate scheduler', function () {
18+
newBufferWithImmediateScheduler.subscribe(_next, _error, _complete);
19+
});
1820
};

perf/micro/immediate-scheduler/subject/replaysubject.js

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,12 @@ module.exports = function (suite) {
66
var newRangeWithImmediateScheduler = RxNew.Observable.range(0, 25);
77

88
return suite
9-
.add('old ReplaySubject with immediate scheduler', function () {
10-
var subject = new RxOld.ReplaySubject(5, Number.POSITIVE_INFINITY, RxOld.Scheduler.immediate);
11-
oldRangeWithImmediateScheduler.subscribe(subject);
12-
})
13-
.add('new ReplaySubject with immediate scheduler', function () {
14-
var subject = new RxNew.ReplaySubject(5, Number.POSITIVE_INFINITY);
15-
newRangeWithImmediateScheduler.subscribe(subject);
16-
});
9+
.add('old ReplaySubject with immediate scheduler', function () {
10+
var subject = new RxOld.ReplaySubject(5, Number.POSITIVE_INFINITY, RxOld.Scheduler.immediate);
11+
oldRangeWithImmediateScheduler.subscribe(subject);
12+
})
13+
.add('new ReplaySubject with immediate scheduler', function () {
14+
var subject = new RxNew.ReplaySubject(5, Number.POSITIVE_INFINITY);
15+
newRangeWithImmediateScheduler.subscribe(subject);
16+
});
1717
};

perf/micro/immediate-scheduler/subject/replaysubject_windowtime.js

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,12 @@ module.exports = function (suite) {
66
var newRangeWithImmediateScheduler = RxNew.Observable.range(0, 25);
77

88
return suite
9-
.add('old ReplaySubject with immediate scheduler', function () {
10-
var subject = new RxOld.ReplaySubject(5, 50, RxOld.Scheduler.immediate);
11-
oldRangeWithImmediateScheduler.subscribe(subject);
12-
})
13-
.add('new ReplaySubject with immediate scheduler', function () {
14-
var subject = new RxNew.ReplaySubject(5, 50);
15-
newRangeWithImmediateScheduler.subscribe(subject);
16-
});
9+
.add('old ReplaySubject with immediate scheduler', function () {
10+
var subject = new RxOld.ReplaySubject(5, 50, RxOld.Scheduler.immediate);
11+
oldRangeWithImmediateScheduler.subscribe(subject);
12+
})
13+
.add('new ReplaySubject with immediate scheduler', function () {
14+
var subject = new RxNew.ReplaySubject(5, 50);
15+
newRangeWithImmediateScheduler.subscribe(subject);
16+
});
1717
};

0 commit comments

Comments
 (0)