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.188.39.197
Domains : Cant Read [ /etc/named.conf ]
User : web

Name	Size	Permission	Date
buffer-util.js	2.84 KB	-rw-rw-r--	2022-08-30 11:49
constants.js	360 B	-rw-rw-r--	2022-08-30 11:49
event-target.js	6.44 KB	-rw-rw-r--	2022-08-30 11:49
extension.js	6.04 KB	-rw-rw-r--	2022-08-30 11:49
limiter.js	1.01 KB	-rw-rw-r--	2022-08-30 11:49
permessage-deflate.js	13.67 KB	-rw-rw-r--	2022-08-30 11:49
receiver.js	14.06 KB	-rw-rw-r--	2022-08-30 11:49
sender.js	10.86 KB	-rw-rw-r--	2022-08-30 11:49
stream.js	4.59 KB	-rw-rw-r--	2022-08-30 11:49
subprotocol.js	1.46 KB	-rw-rw-r--	2022-08-30 11:49
validation.js	3.07 KB	-rw-rw-r--	2022-08-30 11:49
websocket-server.js	13.38 KB	-rw-rw-r--	2022-08-30 11:49
websocket.js	28.9 KB	-rw-rw-r--	2022-08-30 11:49

Rename

'use strict';

const kDone = Symbol('kDone');
const kRun = Symbol('kRun');

/**
 * A very simple job queue with adjustable concurrency. Adapted from
 * https://github.com/STRML/async-limiter
 */
class Limiter {
  /**
   * Creates a new `Limiter`.
   *
   * @param {Number} [concurrency=Infinity] The maximum number of jobs allowed
   *     to run concurrently
   */
  constructor(concurrency) {
    this[kDone] = () => {
      this.pending--;
      this[kRun]();
    };
    this.concurrency = concurrency || Infinity;
    this.jobs = [];
    this.pending = 0;
  }

/**
   * Adds a job to the queue.
   *
   * @param {Function} job The job to run
   * @public
   */
  add(job) {
    this.jobs.push(job);
    this[kRun]();
  }

/**
   * Removes a job from the queue and runs it if possible.
   *
   * @private
   */
  [kRun]() {
    if (this.pending === this.concurrency) return;

if (this.jobs.length) {
      const job = this.jobs.shift();

this.pending++;
      job(this[kDone]);
    }
  }
}

module.exports = Limiter;