aboutsummaryrefslogtreecommitdiffstats
path: root/node_modules/rxjs/dist/esm/internal/scheduler/AsapScheduler.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/rxjs/dist/esm/internal/scheduler/AsapScheduler.js')
-rw-r--r--node_modules/rxjs/dist/esm/internal/scheduler/AsapScheduler.js24
1 files changed, 24 insertions, 0 deletions
diff --git a/node_modules/rxjs/dist/esm/internal/scheduler/AsapScheduler.js b/node_modules/rxjs/dist/esm/internal/scheduler/AsapScheduler.js
new file mode 100644
index 0000000..2aa86c9
--- /dev/null
+++ b/node_modules/rxjs/dist/esm/internal/scheduler/AsapScheduler.js
@@ -0,0 +1,24 @@
+import { AsyncScheduler } from './AsyncScheduler';
+export class AsapScheduler extends AsyncScheduler {
+ flush(action) {
+ this._active = true;
+ const flushId = this._scheduled;
+ this._scheduled = undefined;
+ const { actions } = this;
+ let error;
+ action = action || actions.shift();
+ do {
+ if ((error = action.execute(action.state, action.delay))) {
+ break;
+ }
+ } while ((action = actions[0]) && action.id === flushId && actions.shift());
+ this._active = false;
+ if (error) {
+ while ((action = actions[0]) && action.id === flushId && actions.shift()) {
+ action.unsubscribe();
+ }
+ throw error;
+ }
+ }
+}
+//# sourceMappingURL=AsapScheduler.js.map \ No newline at end of file
send patches to the email below
yukais@pinapelz.com
include the subject [PATCH repo_name]
pinapelz.com
homepage