diff options
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/src/internal/scheduler/AsapAction.ts')
-rw-r--r-- | tools/node_modules/eslint/node_modules/rxjs/src/internal/scheduler/AsapAction.ts | 48 |
1 files changed, 0 insertions, 48 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/src/internal/scheduler/AsapAction.ts b/tools/node_modules/eslint/node_modules/rxjs/src/internal/scheduler/AsapAction.ts deleted file mode 100644 index 1fe1622db9..0000000000 --- a/tools/node_modules/eslint/node_modules/rxjs/src/internal/scheduler/AsapAction.ts +++ /dev/null @@ -1,48 +0,0 @@ -import { Immediate } from '../util/Immediate'; -import { AsyncAction } from './AsyncAction'; -import { AsapScheduler } from './AsapScheduler'; -import { SchedulerAction } from '../types'; -/** - * We need this JSDoc comment for affecting ESDoc. - * @ignore - * @extends {Ignored} - */ -export class AsapAction<T> extends AsyncAction<T> { - - constructor(protected scheduler: AsapScheduler, - protected work: (this: SchedulerAction<T>, state?: T) => void) { - super(scheduler, work); - } - - protected requestAsyncId(scheduler: AsapScheduler, id?: any, delay: number = 0): any { - // 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) - )); - } - protected recycleAsyncId(scheduler: AsapScheduler, id?: any, delay: number = 0): any { - // 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; - } -} |