Gecko [ unitednationsplay.com ]

Linux unitednationsplay.com 3.10.0-1160.45.1.el7.x86_64 #1 SMP Wed Oct 13 17:20:51 UTC 2021 x86_64
nginx/1.20.1
Server IP : 188.130.139.92 & Your IP : 18.219.197.162
Domains : Cant Read [ /etc/named.conf ]
User : web

Name	Size	Permission	Date
Action.ts	1.21 KB	-rw-rw-r--	2022-08-30 11:49
AnimationFrameAction.ts	2.05 KB	-rw-rw-r--	2022-08-30 11:49
AnimationFrameScheduler.ts	756 B	-rw-rw-r--	2022-08-30 11:49
AsapAction.ts	1.92 KB	-rw-rw-r--	2022-08-30 11:49
AsapScheduler.ts	746 B	-rw-rw-r--	2022-08-30 11:49
AsyncAction.ts	4.84 KB	-rw-rw-r--	2022-08-30 11:49
AsyncScheduler.ts	1.08 KB	-rw-rw-r--	2022-08-30 11:49
QueueAction.ts	1.35 KB	-rw-rw-r--	2022-08-30 11:49
QueueScheduler.ts	107 B	-rw-rw-r--	2022-08-30 11:49
VirtualTimeScheduler.ts	2.89 KB	-rw-rw-r--	2022-08-30 11:49
animationFrame.ts	1.18 KB	-rw-rw-r--	2022-08-30 11:49
asap.ts	1.56 KB	-rw-rw-r--	2022-08-30 11:49
async.ts	1.38 KB	-rw-rw-r--	2022-08-30 11:49
queue.ts	1.91 KB	-rw-rw-r--	2022-08-30 11:49

Rename

import { Scheduler } from '../Scheduler';
import { AsyncAction } from './AsyncAction';

export class AsyncScheduler extends Scheduler {
  public actions: Array<AsyncAction<any>> = [];
  /**
   * A flag to indicate whether the Scheduler is currently executing a batch of
   * queued actions.
   * @type {boolean}
   */
  public active: boolean = false;
  /**
   * An internal ID used to track the latest asynchronous task such as those
   * coming from `setTimeout`, `setInterval`, `requestAnimationFrame`, and
   * others.
   * @type {any}
   */
  public scheduled: any = undefined;

public flush(action: AsyncAction<any>): void {

const {actions} = this;

if (this.active) {
      actions.push(action);
      return;
    }

let error: any;
    this.active = true;

do {
      if (error = action.execute(action.state, action.delay)) {
        break;
      }
    } while (action = actions.shift()); // exhaust the scheduler queue

this.active = false;

if (error) {
      while (action = actions.shift()) {
        action.unsubscribe();
      }
      throw error;
    }
  }
}