diff options
| author | Pinapelz <yukais@pinapelz.com> | 2025-06-28 17:26:46 -0700 |
|---|---|---|
| committer | Pinapelz <yukais@pinapelz.com> | 2025-06-28 17:43:56 -0700 |
| commit | e4fa1e69e7ebfb627c7198fd1a9881e9327ec4d4 (patch) | |
| tree | 06284a538a6008eca75051399e47db4e5d50301c /node_modules/rxjs/dist/esm/internal/scheduler/QueueAction.js | |
initial commit: scaffolding
Diffstat (limited to 'node_modules/rxjs/dist/esm/internal/scheduler/QueueAction.js')
| -rw-r--r-- | node_modules/rxjs/dist/esm/internal/scheduler/QueueAction.js | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/node_modules/rxjs/dist/esm/internal/scheduler/QueueAction.js b/node_modules/rxjs/dist/esm/internal/scheduler/QueueAction.js new file mode 100644 index 0000000..002b94a --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduler/QueueAction.js @@ -0,0 +1,28 @@ +import { AsyncAction } from './AsyncAction'; +export class QueueAction extends AsyncAction { + constructor(scheduler, work) { + super(scheduler, work); + this.scheduler = scheduler; + this.work = work; + } + schedule(state, delay = 0) { + if (delay > 0) { + return super.schedule(state, delay); + } + this.delay = delay; + this.state = state; + this.scheduler.flush(this); + return this; + } + execute(state, delay) { + return delay > 0 || this.closed ? super.execute(state, delay) : this._execute(state, delay); + } + requestAsyncId(scheduler, id, delay = 0) { + if ((delay != null && delay > 0) || (delay == null && this.delay > 0)) { + return super.requestAsyncId(scheduler, id, delay); + } + scheduler.flush(this); + return 0; + } +} +//# sourceMappingURL=QueueAction.js.map
\ No newline at end of file |
