1 | var __classPrivateFieldGet = (this && this.__classPrivateFieldGet) || function (receiver, state, kind, f) {
|
2 | if (kind === "a" && !f) throw new TypeError("Private accessor was defined without a getter");
|
3 | if (typeof state === "function" ? receiver !== state || !f : !state.has(receiver)) throw new TypeError("Cannot read private member from an object whose class did not declare it");
|
4 | return kind === "m" ? f : kind === "a" ? f.call(receiver) : f ? f.value : state.get(receiver);
|
5 | };
|
6 | var _PriorityQueue_queue;
|
7 | import lowerBound from './lower-bound.js';
|
8 | export default class PriorityQueue {
|
9 | constructor() {
|
10 | _PriorityQueue_queue.set(this, []);
|
11 | }
|
12 | enqueue(run, options) {
|
13 | options = {
|
14 | priority: 0,
|
15 | ...options,
|
16 | };
|
17 | const element = {
|
18 | priority: options.priority,
|
19 | run,
|
20 | };
|
21 | if (this.size && __classPrivateFieldGet(this, _PriorityQueue_queue, "f")[this.size - 1].priority >= options.priority) {
|
22 | __classPrivateFieldGet(this, _PriorityQueue_queue, "f").push(element);
|
23 | return;
|
24 | }
|
25 | const index = lowerBound(__classPrivateFieldGet(this, _PriorityQueue_queue, "f"), element, (a, b) => b.priority - a.priority);
|
26 | __classPrivateFieldGet(this, _PriorityQueue_queue, "f").splice(index, 0, element);
|
27 | }
|
28 | dequeue() {
|
29 | const item = __classPrivateFieldGet(this, _PriorityQueue_queue, "f").shift();
|
30 | return item === null || item === void 0 ? void 0 : item.run;
|
31 | }
|
32 | filter(options) {
|
33 | return __classPrivateFieldGet(this, _PriorityQueue_queue, "f").filter((element) => element.priority === options.priority).map((element) => element.run);
|
34 | }
|
35 | get size() {
|
36 | return __classPrivateFieldGet(this, _PriorityQueue_queue, "f").length;
|
37 | }
|
38 | }
|
39 | _PriorityQueue_queue = new WeakMap();
|