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

Commit e73e312

Browse files
mattpodwysockimattpodwysocki
committed
Closing scopes
1 parent 1ad1e89 commit e73e312

28 files changed

+119
-79
lines changed

‎dist/rx.all.compat.js

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1271,6 +1271,14 @@
12711271
}
12721272
}
12731273

1274+
function invokeRecDateRelative(s, p) {
1275+
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
1276+
}
1277+
1278+
function invokeRecDateAbsolute(s, p) {
1279+
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
1280+
}
1281+
12741282
function scheduleInnerRecursive(action, self) {
12751283
action(function(dt) { self(action, dt); });
12761284
}
@@ -1312,9 +1320,7 @@
13121320
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
13131321
*/
13141322
schedulerProto.scheduleRecursiveWithRelativeAndState = function (state, dueTime, action) {
1315-
return this._scheduleRelative([state, action], dueTime, function (s, p) {
1316-
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
1317-
});
1323+
return this._scheduleRelative([state, action], dueTime, invokeRecDateRelative);
13181324
};
13191325

13201326
/**
@@ -1335,9 +1341,7 @@
13351341
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
13361342
*/
13371343
schedulerProto.scheduleRecursiveWithAbsoluteAndState = function (state, dueTime, action) {
1338-
return this._scheduleAbsolute([state, action], dueTime, function (s, p) {
1339-
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
1340-
});
1344+
return this._scheduleAbsolute([state, action], dueTime, invokeRecDateAbsolute);
13411345
};
13421346
}(Scheduler.prototype));
13431347

‎dist/rx.all.compat.map

Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.

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

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.js

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1080,6 +1080,14 @@
10801080
}
10811081
}
10821082

1083+
function invokeRecDateRelative(s, p) {
1084+
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
1085+
}
1086+
1087+
function invokeRecDateAbsolute(s, p) {
1088+
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
1089+
}
1090+
10831091
function scheduleInnerRecursive(action, self) {
10841092
action(function(dt) { self(action, dt); });
10851093
}
@@ -1121,9 +1129,7 @@
11211129
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
11221130
*/
11231131
schedulerProto.scheduleRecursiveWithRelativeAndState = function (state, dueTime, action) {
1124-
return this._scheduleRelative([state, action], dueTime, function (s, p) {
1125-
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
1126-
});
1132+
return this._scheduleRelative([state, action], dueTime, invokeRecDateRelative);
11271133
};
11281134

11291135
/**
@@ -1144,9 +1150,7 @@
11441150
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
11451151
*/
11461152
schedulerProto.scheduleRecursiveWithAbsoluteAndState = function (state, dueTime, action) {
1147-
return this._scheduleAbsolute([state, action], dueTime, function (s, p) {
1148-
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
1149-
});
1153+
return this._scheduleAbsolute([state, action], dueTime, invokeRecDateAbsolute);
11501154
};
11511155
}(Scheduler.prototype));
11521156

‎dist/rx.all.map

Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.

‎dist/rx.all.min.js

Lines changed: 2 additions & 2 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: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1185,6 +1185,14 @@
11851185
}
11861186
}
11871187

1188+
function invokeRecDateRelative(s, p) {
1189+
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
1190+
}
1191+
1192+
function invokeRecDateAbsolute(s, p) {
1193+
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
1194+
}
1195+
11881196
function scheduleInnerRecursive(action, self) {
11891197
action(function(dt) { self(action, dt); });
11901198
}
@@ -1226,9 +1234,7 @@
12261234
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
12271235
*/
12281236
schedulerProto.scheduleRecursiveWithRelativeAndState = function (state, dueTime, action) {
1229-
return this._scheduleRelative([state, action], dueTime, function (s, p) {
1230-
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
1231-
});
1237+
return this._scheduleRelative([state, action], dueTime, invokeRecDateRelative);
12321238
};
12331239

12341240
/**
@@ -1249,9 +1255,7 @@
12491255
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
12501256
*/
12511257
schedulerProto.scheduleRecursiveWithAbsoluteAndState = function (state, dueTime, action) {
1252-
return this._scheduleAbsolute([state, action], dueTime, function (s, p) {
1253-
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
1254-
});
1258+
return this._scheduleAbsolute([state, action], dueTime, invokeRecDateAbsolute);
12551259
};
12561260
}(Scheduler.prototype));
12571261

‎dist/rx.compat.map

Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.

‎dist/rx.compat.min.js

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.core.js

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -559,6 +559,14 @@ var
559559
}
560560
}
561561

562+
function invokeRecDateRelative(s, p) {
563+
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
564+
}
565+
566+
function invokeRecDateAbsolute(s, p) {
567+
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
568+
}
569+
562570
function scheduleInnerRecursive(action, self) {
563571
action(function(dt) { self(action, dt); });
564572
}
@@ -600,9 +608,7 @@ var
600608
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
601609
*/
602610
schedulerProto.scheduleRecursiveWithRelativeAndState = function (state, dueTime, action) {
603-
return this._scheduleRelative([state, action], dueTime, function (s, p) {
604-
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
605-
});
611+
return this._scheduleRelative([state, action], dueTime, invokeRecDateRelative);
606612
};
607613

608614
/**
@@ -623,9 +629,7 @@ var
623629
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
624630
*/
625631
schedulerProto.scheduleRecursiveWithAbsoluteAndState = function (state, dueTime, action) {
626-
return this._scheduleAbsolute([state, action], dueTime, function (s, p) {
627-
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
628-
});
632+
return this._scheduleAbsolute([state, action], dueTime, invokeRecDateAbsolute);
629633
};
630634
}(Scheduler.prototype));
631635

‎dist/rx.core.map

Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.

‎dist/rx.core.min.js

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.js

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -994,6 +994,14 @@
994994
}
995995
}
996996

997+
function invokeRecDateRelative(s, p) {
998+
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
999+
}
1000+
1001+
function invokeRecDateAbsolute(s, p) {
1002+
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
1003+
}
1004+
9971005
function scheduleInnerRecursive(action, self) {
9981006
action(function(dt) { self(action, dt); });
9991007
}
@@ -1035,9 +1043,7 @@
10351043
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
10361044
*/
10371045
schedulerProto.scheduleRecursiveWithRelativeAndState = function (state, dueTime, action) {
1038-
return this._scheduleRelative([state, action], dueTime, function (s, p) {
1039-
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
1040-
});
1046+
return this._scheduleRelative([state, action], dueTime, invokeRecDateRelative);
10411047
};
10421048

10431049
/**
@@ -1058,9 +1064,7 @@
10581064
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
10591065
*/
10601066
schedulerProto.scheduleRecursiveWithAbsoluteAndState = function (state, dueTime, action) {
1061-
return this._scheduleAbsolute([state, action], dueTime, function (s, p) {
1062-
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
1063-
});
1067+
return this._scheduleAbsolute([state, action], dueTime, invokeRecDateAbsolute);
10641068
};
10651069
}(Scheduler.prototype));
10661070

‎dist/rx.lite.compat.js

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1170,6 +1170,14 @@
11701170
}
11711171
}
11721172

1173+
function invokeRecDateRelative(s, p) {
1174+
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
1175+
}
1176+
1177+
function invokeRecDateAbsolute(s, p) {
1178+
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
1179+
}
1180+
11731181
function scheduleInnerRecursive(action, self) {
11741182
action(function(dt) { self(action, dt); });
11751183
}
@@ -1211,9 +1219,7 @@
12111219
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
12121220
*/
12131221
schedulerProto.scheduleRecursiveWithRelativeAndState = function (state, dueTime, action) {
1214-
return this._scheduleRelative([state, action], dueTime, function (s, p) {
1215-
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
1216-
});
1222+
return this._scheduleRelative([state, action], dueTime, invokeRecDateRelative);
12171223
};
12181224

12191225
/**
@@ -1234,9 +1240,7 @@
12341240
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
12351241
*/
12361242
schedulerProto.scheduleRecursiveWithAbsoluteAndState = function (state, dueTime, action) {
1237-
return this._scheduleAbsolute([state, action], dueTime, function (s, p) {
1238-
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
1239-
});
1243+
return this._scheduleAbsolute([state, action], dueTime, invokeRecDateAbsolute);
12401244
};
12411245
}(Scheduler.prototype));
12421246

‎dist/rx.lite.compat.map

Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.

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

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.lite.js

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -981,6 +981,14 @@
981981
}
982982
}
983983

984+
function invokeRecDateRelative(s, p) {
985+
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
986+
}
987+
988+
function invokeRecDateAbsolute(s, p) {
989+
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
990+
}
991+
984992
function scheduleInnerRecursive(action, self) {
985993
action(function(dt) { self(action, dt); });
986994
}
@@ -1022,9 +1030,7 @@
10221030
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
10231031
*/
10241032
schedulerProto.scheduleRecursiveWithRelativeAndState = function (state, dueTime, action) {
1025-
return this._scheduleRelative([state, action], dueTime, function (s, p) {
1026-
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
1027-
});
1033+
return this._scheduleRelative([state, action], dueTime, invokeRecDateRelative);
10281034
};
10291035

10301036
/**
@@ -1045,9 +1051,7 @@
10451051
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
10461052
*/
10471053
schedulerProto.scheduleRecursiveWithAbsoluteAndState = function (state, dueTime, action) {
1048-
return this._scheduleAbsolute([state, action], dueTime, function (s, p) {
1049-
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
1050-
});
1054+
return this._scheduleAbsolute([state, action], dueTime, invokeRecDateAbsolute);
10511055
};
10521056
}(Scheduler.prototype));
10531057

‎dist/rx.lite.map

Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.

‎dist/rx.lite.min.js

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.map

Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.

‎dist/rx.min.js

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

‎modules/rx-lite-compat/rx.lite.compat.js

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1170,6 +1170,14 @@
11701170
}
11711171
}
11721172

1173+
function invokeRecDateRelative(s, p) {
1174+
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
1175+
}
1176+
1177+
function invokeRecDateAbsolute(s, p) {
1178+
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
1179+
}
1180+
11731181
function scheduleInnerRecursive(action, self) {
11741182
action(function(dt) { self(action, dt); });
11751183
}
@@ -1211,9 +1219,7 @@
12111219
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
12121220
*/
12131221
schedulerProto.scheduleRecursiveWithRelativeAndState = function (state, dueTime, action) {
1214-
return this._scheduleRelative([state, action], dueTime, function (s, p) {
1215-
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
1216-
});
1222+
return this._scheduleRelative([state, action], dueTime, invokeRecDateRelative);
12171223
};
12181224

12191225
/**
@@ -1234,9 +1240,7 @@
12341240
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
12351241
*/
12361242
schedulerProto.scheduleRecursiveWithAbsoluteAndState = function (state, dueTime, action) {
1237-
return this._scheduleAbsolute([state, action], dueTime, function (s, p) {
1238-
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
1239-
});
1243+
return this._scheduleAbsolute([state, action], dueTime, invokeRecDateAbsolute);
12401244
};
12411245
}(Scheduler.prototype));
12421246

‎modules/rx-lite-compat/rx.lite.compat.map

Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.

‎modules/rx-lite-compat/rx.lite.compat.min.js

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

‎modules/rx-lite/rx.lite.js

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -981,6 +981,14 @@
981981
}
982982
}
983983

984+
function invokeRecDateRelative(s, p) {
985+
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
986+
}
987+
988+
function invokeRecDateAbsolute(s, p) {
989+
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
990+
}
991+
984992
function scheduleInnerRecursive(action, self) {
985993
action(function(dt) { self(action, dt); });
986994
}
@@ -1022,9 +1030,7 @@
10221030
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
10231031
*/
10241032
schedulerProto.scheduleRecursiveWithRelativeAndState = function (state, dueTime, action) {
1025-
return this._scheduleRelative([state, action], dueTime, function (s, p) {
1026-
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
1027-
});
1033+
return this._scheduleRelative([state, action], dueTime, invokeRecDateRelative);
10281034
};
10291035

10301036
/**
@@ -1045,9 +1051,7 @@
10451051
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
10461052
*/
10471053
schedulerProto.scheduleRecursiveWithAbsoluteAndState = function (state, dueTime, action) {
1048-
return this._scheduleAbsolute([state, action], dueTime, function (s, p) {
1049-
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
1050-
});
1054+
return this._scheduleAbsolute([state, action], dueTime, invokeRecDateAbsolute);
10511055
};
10521056
}(Scheduler.prototype));
10531057

‎modules/rx-lite/rx.lite.map

Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.

‎modules/rx-lite/rx.lite.min.js

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

‎src/core/concurrency/scheduler.recursive.js

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,14 @@
5252
}
5353
}
5454

55+
function invokeRecDateRelative(s, p) {
56+
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
57+
}
58+
59+
function invokeRecDateAbsolute(s, p) {
60+
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
61+
}
62+
5563
function scheduleInnerRecursive(action, self) {
5664
action(function(dt) { self(action, dt); });
5765
}
@@ -93,9 +101,7 @@
93101
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
94102
*/
95103
schedulerProto.scheduleRecursiveWithRelativeAndState = function (state, dueTime, action) {
96-
return this._scheduleRelative([state, action], dueTime, function (s, p) {
97-
return invokeRecDate(s, p, 'scheduleWithRelativeAndState');
98-
});
104+
return this._scheduleRelative([state, action], dueTime, invokeRecDateRelative);
99105
};
100106

101107
/**
@@ -116,8 +122,6 @@
116122
* @returns {Disposable} The disposable object used to cancel the scheduled action (best effort).
117123
*/
118124
schedulerProto.scheduleRecursiveWithAbsoluteAndState = function (state, dueTime, action) {
119-
return this._scheduleAbsolute([state, action], dueTime, function (s, p) {
120-
return invokeRecDate(s, p, 'scheduleWithAbsoluteAndState');
121-
});
125+
return this._scheduleAbsolute([state, action], dueTime, invokeRecDateAbsolute);
122126
};
123127
}(Scheduler.prototype));

0 commit comments

Comments
 (0)