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

Commit 2e476e3

Browse files
Cleaning up scheduler
1 parent 2d5c671 commit 2e476e3

27 files changed

Lines changed: 75 additions & 69 deletions

dist/rx.all.compat.js

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1244,7 +1244,6 @@
12441244
}
12451245
});
12461246
}
1247-
12481247
recursiveAction(state);
12491248
return group;
12501249
}
@@ -1283,8 +1282,7 @@
12831282
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
12841283
*/
12851284
schedulerProto.scheduleRecursive = function (action) {
1286-
return this.scheduleRecursiveWithState(action, function (_action, self) {
1287-
_action(function () { self(_action); }); });
1285+
return this.scheduleRecursiveWithState(action, scheduleInnerRecursive);
12881286
};
12891287

12901288
/**
@@ -5359,7 +5357,7 @@
53595357
return true;
53605358
}
53615359
return false;
5362-
}
5360+
};
53635361

53645362
return TakeObservable;
53655363
}(ObservableBase));

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 & 4 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: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1053,7 +1053,6 @@
10531053
}
10541054
});
10551055
}
1056-
10571056
recursiveAction(state);
10581057
return group;
10591058
}
@@ -1092,8 +1091,7 @@
10921091
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
10931092
*/
10941093
schedulerProto.scheduleRecursive = function (action) {
1095-
return this.scheduleRecursiveWithState(action, function (_action, self) {
1096-
_action(function () { self(_action); }); });
1094+
return this.scheduleRecursiveWithState(action, scheduleInnerRecursive);
10971095
};
10981096

10991097
/**
@@ -5214,7 +5212,7 @@
52145212
return true;
52155213
}
52165214
return false;
5217-
}
5215+
};
52185216

52195217
return TakeObservable;
52205218
}(ObservableBase));

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: 4 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: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1244,7 +1244,6 @@
12441244
}
12451245
});
12461246
}
1247-
12481247
recursiveAction(state);
12491248
return group;
12501249
}
@@ -1283,8 +1282,7 @@
12831282
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
12841283
*/
12851284
schedulerProto.scheduleRecursive = function (action) {
1286-
return this.scheduleRecursiveWithState(action, function (_action, self) {
1287-
_action(function () { self(_action); }); });
1285+
return this.scheduleRecursiveWithState(action, scheduleInnerRecursive);
12881286
};
12891287

12901288
/**
@@ -5245,7 +5243,7 @@
52455243
return true;
52465244
}
52475245
return false;
5248-
}
5246+
};
52495247

52505248
return TakeObservable;
52515249
}(ObservableBase));

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 & 4 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

dist/rx.js

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1053,7 +1053,6 @@
10531053
}
10541054
});
10551055
}
1056-
10571056
recursiveAction(state);
10581057
return group;
10591058
}
@@ -1092,8 +1091,7 @@
10921091
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
10931092
*/
10941093
schedulerProto.scheduleRecursive = function (action) {
1095-
return this.scheduleRecursiveWithState(action, function (_action, self) {
1096-
_action(function () { self(_action); }); });
1094+
return this.scheduleRecursiveWithState(action, scheduleInnerRecursive);
10971095
};
10981096

10991097
/**
@@ -5054,7 +5052,7 @@
50545052
return true;
50555053
}
50565054
return false;
5057-
}
5055+
};
50585056

50595057
return TakeObservable;
50605058
}(ObservableBase));

0 commit comments

Comments
 (0)