File Explorer

1"use strict";2/*3 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.4 * SPDX-License-Identifier: Apache-2.0.5 */6var __extends = (this && this.__extends) || (function () {7    var extendStatics = function (d, b) {8        extendStatics = Object.setPrototypeOf ||9            ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||10            function (d, b) { for (var p in b) if (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; };11        return extendStatics(d, b);12    };13    return function (d, b) {14        if (typeof b !== "function" && b !== null)15            throw new TypeError("Class extends value " + String(b) + " is not a constructor or null");16        extendStatics(d, b);17        function __() { this.constructor = d; }18        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());19    };20})();21var __read = (this && this.__read) || function (o, n) {22    var m = typeof Symbol === "function" && o[Symbol.iterator];23    if (!m) return o;24    var i = m.call(o), r, ar = [], e;25    try {26        while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);27    }28    catch (error) { e = { error: error }; }29    finally {30        try {31            if (r && !r.done && (m = i["return"])) m.call(i);32        }33        finally { if (e) throw e.error; }34    }35    return ar;36};37var __spreadArray = (this && this.__spreadArray) || function (to, from, pack) {38    if (pack || arguments.length === 2) for (var i = 0, l = from.length, ar; i < l; i++) {39        if (ar || !(i in from)) {40            if (!ar) ar = Array.prototype.slice.call(from, 0, i);41            ar[i] = from[i];42        }43    }44    return to.concat(ar || Array.prototype.slice.call(from));45};46Object.defineProperty(exports, "__esModule", { value: true });47exports.BufferedEventEmitter = void 0;48/**49 * Module for base types related to event emission50 *51 * @packageDocumentation52 * @module event53 */54var events_1 = require("events");55/**56 * @internal57 */58var BufferedEvent = /** @class */ (function () {59    function BufferedEvent(event, args) {60        this.event = event;61        this.args = args;62    }63    BufferedEvent.newWithEmissionCallback = function (key, callback, args) {64        var bufferedEvent = new BufferedEvent(key, args);65        bufferedEvent.callback = callback;66        return bufferedEvent;67    };68    return BufferedEvent;69}());70/**71 * Provides buffered event emitting semantics, similar to many Node-style streams.72 * Subclasses will override EventEmitter.on() and trigger uncorking.73 * NOTE: It is HIGHLY recommended that uncorking should always be done via74 * ```process.nextTick()```, not during the EventEmitter.on() call.75 *76 * See also: [Node writable streams](https://nodejs.org/api/stream.html#stream_writable_cork)77 *78 * @category Events79 */80var BufferedEventEmitter = /** @class */ (function (_super) {81    __extends(BufferedEventEmitter, _super);82    function BufferedEventEmitter() {83        var _this = _super.call(this) || this;84        _this.corked = false;85        return _this;86    }87    /**88     * Forces all written events to be buffered in memory. The buffered data will be89     * flushed when {@link BufferedEventEmitter.uncork} is called.90     */91    BufferedEventEmitter.prototype.cork = function () {92        this.corked = true;93    };94    /**95     * Flushes all data buffered since {@link BufferedEventEmitter.cork} was called.96     *97     * NOTE: It is HIGHLY recommended that uncorking should always be done via98     * ``` process.nextTick```, not during the ```EventEmitter.on()``` call.99     */100    BufferedEventEmitter.prototype.uncork = function () {101        this.corked = false;102        while (this.eventQueue) {103            var event_1 = this.eventQueue;104            _super.prototype.emit.apply(this, __spreadArray([event_1.event], __read(event_1.args), false));105            if (event_1.callback) {106                event_1.callback();107            }108            this.eventQueue = this.eventQueue.next;109        }110    };111    /**112     * Synchronously calls each of the listeners registered for the event key supplied113     * in registration order. If the {@link BufferedEventEmitter} is currently corked,114     * the event will be buffered until {@link BufferedEventEmitter.uncork} is called.115     * @param event The name of the event116     * @param args Event payload117     */118    BufferedEventEmitter.prototype.emit = function (event) {119        var args = [];120        for (var _i = 1; _i < arguments.length; _i++) {121            args[_i - 1] = arguments[_i];122        }123        if (this.corked) {124            // queue requests in order125            var last = this.lastQueuedEvent;126            this.lastQueuedEvent = new BufferedEvent(event, args);127            if (last) {128                last.next = this.lastQueuedEvent;129            }130            else {131                this.eventQueue = this.lastQueuedEvent;132            }133            return this.listeners(event).length > 0;134        }135        return _super.prototype.emit.apply(this, __spreadArray([event], __read(args), false));136    };137    BufferedEventEmitter.prototype.emitWithCallback = function (event, emissionCallback) {138        var args = [];139        for (var _i = 2; _i < arguments.length; _i++) {140            args[_i - 2] = arguments[_i];141        }142        if (this.corked) {143            // queue requests in order144            var last = this.lastQueuedEvent;145            this.lastQueuedEvent = BufferedEvent.newWithEmissionCallback(event, emissionCallback, args);146            if (last) {147                last.next = this.lastQueuedEvent;148            }149            else {150                this.eventQueue = this.lastQueuedEvent;151            }152            return this.listeners(event).length > 0;153        }154        var result = _super.prototype.emit.apply(this, __spreadArray([event], __read(args), false));155        emissionCallback();156        return result;157    };158    return BufferedEventEmitter;159}(events_1.EventEmitter));160exports.BufferedEventEmitter = BufferedEventEmitter;161//# sourceMappingURL=event.js.map