From e4fa1e69e7ebfb627c7198fd1a9881e9327ec4d4 Mon Sep 17 00:00:00 2001 From: Pinapelz Date: Sat, 28 Jun 2025 17:26:46 -0700 Subject: initial commit: scaffolding --- .../rxjs/dist/esm/internal/scheduler/AsapAction.js | 31 ++++++++++++++++++++++ 1 file changed, 31 insertions(+) create mode 100644 node_modules/rxjs/dist/esm/internal/scheduler/AsapAction.js (limited to 'node_modules/rxjs/dist/esm/internal/scheduler/AsapAction.js') diff --git a/node_modules/rxjs/dist/esm/internal/scheduler/AsapAction.js b/node_modules/rxjs/dist/esm/internal/scheduler/AsapAction.js new file mode 100644 index 0000000..8a2ba77 --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduler/AsapAction.js @@ -0,0 +1,31 @@ +import { AsyncAction } from './AsyncAction'; +import { immediateProvider } from './immediateProvider'; +export class AsapAction extends AsyncAction { + constructor(scheduler, work) { + super(scheduler, work); + this.scheduler = scheduler; + this.work = work; + } + requestAsyncId(scheduler, id, delay = 0) { + if (delay !== null && delay > 0) { + return super.requestAsyncId(scheduler, id, delay); + } + scheduler.actions.push(this); + return scheduler._scheduled || (scheduler._scheduled = immediateProvider.setImmediate(scheduler.flush.bind(scheduler, undefined))); + } + recycleAsyncId(scheduler, id, delay = 0) { + var _a; + if (delay != null ? delay > 0 : this.delay > 0) { + return super.recycleAsyncId(scheduler, id, delay); + } + const { actions } = scheduler; + if (id != null && ((_a = actions[actions.length - 1]) === null || _a === void 0 ? void 0 : _a.id) !== id) { + immediateProvider.clearImmediate(id); + if (scheduler._scheduled === id) { + scheduler._scheduled = undefined; + } + } + return undefined; + } +} +//# sourceMappingURL=AsapAction.js.map \ No newline at end of file -- cgit v1.2.3