Skip to content

Commit aca2d37

Browse files
committed
test(scan): add scan micro perf tests for seeded or seedless over scalars
1 parent 4c65136 commit aca2d37

File tree

2 files changed

+24
-2
lines changed

2 files changed

+24
-2
lines changed
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
var RxOld = require('rx');
2+
var RxNew = require('../../../../index');
3+
4+
module.exports = function (suite) {
5+
function add(acc, x) {
6+
return x + x;
7+
}
8+
9+
var oldScanScalarWithImmediateScheduler = RxOld.Observable.of(25, RxOld.Scheduler.immediate).scan(add);
10+
var newScanScalarWithImmediateScheduler = RxNew.Observable.of(25).scan(add);
11+
12+
function _next(x) { }
13+
function _error(e) { }
14+
function _complete() { }
15+
return suite
16+
.add('old scalar observable scan with immediate scheduler with no seed', function () {
17+
oldScanScalarWithImmediateScheduler.subscribe(_next, _error, _complete);
18+
})
19+
.add('new scalar observable scan with immediate scheduler with no seed', function () {
20+
newScanScalarWithImmediateScheduler.subscribe(_next, _error, _complete);
21+
});
22+
};

perf/micro/immediate-scheduler/operators/scan-scalar.js

+2-2
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,8 @@ module.exports = function (suite) {
66
return x + x;
77
}
88

9-
var oldScanScalarWithImmediateScheduler = RxOld.Observable.of(25, RxOld.Scheduler.immediate).scan(add);
10-
var newScanScalarWithImmediateScheduler = RxNew.Observable.of(25).scan(add);
9+
var oldScanScalarWithImmediateScheduler = RxOld.Observable.of(25, RxOld.Scheduler.immediate).scan(add, 0);
10+
var newScanScalarWithImmediateScheduler = RxNew.Observable.of(25).scan(add, 0);
1111

1212
function _next(x) { }
1313
function _error(e) { }

0 commit comments

Comments
 (0)