Skip to content
This repository was archived by the owner on Apr 20, 2018. It is now read-only.

Commit 41d2ed7

Browse files
mattpodwysockimattpodwysocki
committed
Adding perf for fromArray/range
1 parent 789ceb9 commit 41d2ed7

27 files changed

Lines changed: 195 additions & 126 deletions

‎dist/rx.all.compat.js‎

Lines changed: 16 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -3132,18 +3132,20 @@ var ObserveOnObservable = (function (__super__) {
31323132
this.parent = parent;
31333133
}
31343134

3135-
FromArraySink.prototype.run = function () {
3136-
var observer = this.observer, args = this.parent.args, len = args.length;
3137-
function loopRecursive(i, recurse) {
3135+
function loopRecursive(args, observer) {
3136+
var len = args.length;
3137+
return function loop (i, recurse) {
31383138
if (i < len) {
31393139
observer.onNext(args[i]);
31403140
recurse(i + 1);
31413141
} else {
31423142
observer.onCompleted();
31433143
}
3144-
}
3144+
};
3145+
}
31453146

3146-
return this.parent.scheduler.scheduleRecursive(0, loopRecursive);
3147+
FromArraySink.prototype.run = function () {
3148+
return this.parent.scheduler.scheduleRecursive(0, loopRecursive(this.parent.args, this.observer));
31473149
};
31483150

31493151
/**
@@ -3334,18 +3336,22 @@ var ObserveOnObservable = (function (__super__) {
33343336
this.parent = parent;
33353337
}
33363338

3337-
RangeSink.prototype.run = function () {
3338-
var start = this.parent.start, count = this.parent.rangeCount, observer = this.observer;
3339-
function loopRecursive(i, recurse) {
3339+
function loopRecursive(start, count, observer) {
3340+
return function loop (i, recurse) {
33403341
if (i < count) {
33413342
observer.onNext(start + i);
33423343
recurse(i + 1);
33433344
} else {
33443345
observer.onCompleted();
33453346
}
3346-
}
3347+
};
3348+
}
33473349

3348-
return this.parent.scheduler.scheduleRecursive(0, loopRecursive);
3350+
RangeSink.prototype.run = function () {
3351+
return this.parent.scheduler.scheduleRecursive(
3352+
0,
3353+
loopRecursive(this.parent.start, this.parent.rangeCount, this.observer)
3354+
);
33493355
};
33503356

33513357
return RangeSink;

‎dist/rx.all.compat.map‎

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎dist/rx.all.compat.min.js‎

Lines changed: 5 additions & 5 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎dist/rx.all.js‎

Lines changed: 16 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -2764,18 +2764,20 @@ var ObserveOnObservable = (function (__super__) {
27642764
this.parent = parent;
27652765
}
27662766

2767-
FromArraySink.prototype.run = function () {
2768-
var observer = this.observer, args = this.parent.args, len = args.length;
2769-
function loopRecursive(i, recurse) {
2767+
function loopRecursive(args, observer) {
2768+
var len = args.length;
2769+
return function loop (i, recurse) {
27702770
if (i < len) {
27712771
observer.onNext(args[i]);
27722772
recurse(i + 1);
27732773
} else {
27742774
observer.onCompleted();
27752775
}
2776-
}
2776+
};
2777+
}
27772778

2778-
return this.parent.scheduler.scheduleRecursive(0, loopRecursive);
2779+
FromArraySink.prototype.run = function () {
2780+
return this.parent.scheduler.scheduleRecursive(0, loopRecursive(this.parent.args, this.observer));
27792781
};
27802782

27812783
/**
@@ -3012,18 +3014,22 @@ var ObserveOnObservable = (function (__super__) {
30123014
this.parent = parent;
30133015
}
30143016

3015-
RangeSink.prototype.run = function () {
3016-
var start = this.parent.start, count = this.parent.rangeCount, observer = this.observer;
3017-
function loopRecursive(i, recurse) {
3017+
function loopRecursive(start, count, observer) {
3018+
return function loop (i, recurse) {
30183019
if (i < count) {
30193020
observer.onNext(start + i);
30203021
recurse(i + 1);
30213022
} else {
30223023
observer.onCompleted();
30233024
}
3024-
}
3025+
};
3026+
}
30253027

3026-
return this.parent.scheduler.scheduleRecursive(0, loopRecursive);
3028+
RangeSink.prototype.run = function () {
3029+
return this.parent.scheduler.scheduleRecursive(
3030+
0,
3031+
loopRecursive(this.parent.start, this.parent.rangeCount, this.observer)
3032+
);
30273033
};
30283034

30293035
return RangeSink;

‎dist/rx.all.map‎

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎dist/rx.all.min.js‎

Lines changed: 5 additions & 5 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎dist/rx.compat.js‎

Lines changed: 16 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -3132,18 +3132,20 @@ var ObserveOnObservable = (function (__super__) {
31323132
this.parent = parent;
31333133
}
31343134

3135-
FromArraySink.prototype.run = function () {
3136-
var observer = this.observer, args = this.parent.args, len = args.length;
3137-
function loopRecursive(i, recurse) {
3135+
function loopRecursive(args, observer) {
3136+
var len = args.length;
3137+
return function loop (i, recurse) {
31383138
if (i < len) {
31393139
observer.onNext(args[i]);
31403140
recurse(i + 1);
31413141
} else {
31423142
observer.onCompleted();
31433143
}
3144-
}
3144+
};
3145+
}
31453146

3146-
return this.parent.scheduler.scheduleRecursive(0, loopRecursive);
3147+
FromArraySink.prototype.run = function () {
3148+
return this.parent.scheduler.scheduleRecursive(0, loopRecursive(this.parent.args, this.observer));
31473149
};
31483150

31493151
/**
@@ -3334,18 +3336,22 @@ var ObserveOnObservable = (function (__super__) {
33343336
this.parent = parent;
33353337
}
33363338

3337-
RangeSink.prototype.run = function () {
3338-
var start = this.parent.start, count = this.parent.rangeCount, observer = this.observer;
3339-
function loopRecursive(i, recurse) {
3339+
function loopRecursive(start, count, observer) {
3340+
return function loop (i, recurse) {
33403341
if (i < count) {
33413342
observer.onNext(start + i);
33423343
recurse(i + 1);
33433344
} else {
33443345
observer.onCompleted();
33453346
}
3346-
}
3347+
};
3348+
}
33473349

3348-
return this.parent.scheduler.scheduleRecursive(0, loopRecursive);
3350+
RangeSink.prototype.run = function () {
3351+
return this.parent.scheduler.scheduleRecursive(
3352+
0,
3353+
loopRecursive(this.parent.start, this.parent.rangeCount, this.observer)
3354+
);
33493355
};
33503356

33513357
return RangeSink;

‎dist/rx.compat.map‎

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎dist/rx.compat.min.js‎

Lines changed: 3 additions & 3 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎dist/rx.js‎

Lines changed: 16 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -2764,18 +2764,20 @@ var ObserveOnObservable = (function (__super__) {
27642764
this.parent = parent;
27652765
}
27662766

2767-
FromArraySink.prototype.run = function () {
2768-
var observer = this.observer, args = this.parent.args, len = args.length;
2769-
function loopRecursive(i, recurse) {
2767+
function loopRecursive(args, observer) {
2768+
var len = args.length;
2769+
return function loop (i, recurse) {
27702770
if (i < len) {
27712771
observer.onNext(args[i]);
27722772
recurse(i + 1);
27732773
} else {
27742774
observer.onCompleted();
27752775
}
2776-
}
2776+
};
2777+
}
27772778

2778-
return this.parent.scheduler.scheduleRecursive(0, loopRecursive);
2779+
FromArraySink.prototype.run = function () {
2780+
return this.parent.scheduler.scheduleRecursive(0, loopRecursive(this.parent.args, this.observer));
27792781
};
27802782

27812783
/**
@@ -2966,18 +2968,22 @@ var ObserveOnObservable = (function (__super__) {
29662968
this.parent = parent;
29672969
}
29682970

2969-
RangeSink.prototype.run = function () {
2970-
var start = this.parent.start, count = this.parent.rangeCount, observer = this.observer;
2971-
function loopRecursive(i, recurse) {
2971+
function loopRecursive(start, count, observer) {
2972+
return function loop (i, recurse) {
29722973
if (i < count) {
29732974
observer.onNext(start + i);
29742975
recurse(i + 1);
29752976
} else {
29762977
observer.onCompleted();
29772978
}
2978-
}
2979+
};
2980+
}
29792981

2980-
return this.parent.scheduler.scheduleRecursive(0, loopRecursive);
2982+
RangeSink.prototype.run = function () {
2983+
return this.parent.scheduler.scheduleRecursive(
2984+
0,
2985+
loopRecursive(this.parent.start, this.parent.rangeCount, this.observer)
2986+
);
29812987
};
29822988

29832989
return RangeSink;

0 commit comments

Comments
 (0)