You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
44 lines
1.9 KiB
44 lines
1.9 KiB
import { Immediate } from '../util/Immediate'; |
|
import { AsyncAction } from './AsyncAction'; |
|
/** |
|
* We need this JSDoc comment for affecting ESDoc. |
|
* @ignore |
|
* @extends {Ignored} |
|
*/ |
|
export class AsapAction extends AsyncAction { |
|
constructor(scheduler, work) { |
|
super(scheduler, work); |
|
this.scheduler = scheduler; |
|
this.work = work; |
|
} |
|
requestAsyncId(scheduler, id, delay = 0) { |
|
// If delay is greater than 0, request as an async action. |
|
if (delay !== null && delay > 0) { |
|
return super.requestAsyncId(scheduler, id, delay); |
|
} |
|
// Push the action to the end of the scheduler queue. |
|
scheduler.actions.push(this); |
|
// If a microtask has already been scheduled, don't schedule another |
|
// one. If a microtask hasn't been scheduled yet, schedule one now. Return |
|
// the current scheduled microtask id. |
|
return scheduler.scheduled || (scheduler.scheduled = Immediate.setImmediate(scheduler.flush.bind(scheduler, null))); |
|
} |
|
recycleAsyncId(scheduler, id, delay = 0) { |
|
// If delay exists and is greater than 0, or if the delay is null (the |
|
// action wasn't rescheduled) but was originally scheduled as an async |
|
// action, then recycle as an async action. |
|
if ((delay !== null && delay > 0) || (delay === null && this.delay > 0)) { |
|
return super.recycleAsyncId(scheduler, id, delay); |
|
} |
|
// If the scheduler queue is empty, cancel the requested microtask and |
|
// set the scheduled flag to undefined so the next AsapAction will schedule |
|
// its own. |
|
if (scheduler.actions.length === 0) { |
|
Immediate.clearImmediate(id); |
|
scheduler.scheduled = undefined; |
|
} |
|
// Return undefined so the action knows to request a new async id if it's rescheduled. |
|
return undefined; |
|
} |
|
} |
|
//# sourceMappingURL=AsapAction.js.map
|