1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465 |
- "use strict";
- /**
- * Copyright 2022 Google LLC.
- * Copyright (c) Microsoft Corporation.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
- Object.defineProperty(exports, "__esModule", { value: true });
- exports.ProcessingQueue = void 0;
- const log_js_1 = require("./log.js");
- class ProcessingQueue {
- static LOGGER_PREFIX = `${log_js_1.LogType.debug}:queue`;
- #logger;
- #processor;
- #queue = [];
- // Flag to keep only 1 active processor.
- #isProcessing = false;
- constructor(processor, logger) {
- this.#processor = processor;
- this.#logger = logger;
- }
- add(entry, name) {
- this.#queue.push([entry, name]);
- // No need in waiting. Just initialize processor if needed.
- void this.#processIfNeeded();
- }
- async #processIfNeeded() {
- if (this.#isProcessing) {
- return;
- }
- this.#isProcessing = true;
- while (this.#queue.length > 0) {
- const arrayEntry = this.#queue.shift();
- if (!arrayEntry) {
- continue;
- }
- const [entryPromise, name] = arrayEntry;
- this.#logger?.(ProcessingQueue.LOGGER_PREFIX, 'Processing event:', name);
- await entryPromise
- .then((entry) => {
- if (entry.kind === 'error') {
- this.#logger?.(log_js_1.LogType.debugError, 'Event threw before sending:', entry.error.message, entry.error.stack);
- return;
- }
- return this.#processor(entry.value);
- })
- .catch((error) => {
- this.#logger?.(log_js_1.LogType.debugError, 'Event was not processed:', error?.message);
- });
- }
- this.#isProcessing = false;
- }
- }
- exports.ProcessingQueue = ProcessingQueue;
- //# sourceMappingURL=ProcessingQueue.js.map
|