haveno-ts/dist/utils/TaskLooper.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
/**
 * Run a task in a fixed period loop.
 */
class TaskLooper {
    /**
     * Build the looper with a function to invoke on a fixed period loop.
     *
     * @param {function} fn - the async function to invoke
     */
    constructor(fn) {
        this._fn = fn;
        this._isStarted = false;
        this._isLooping = false;
    }
    /**
     * Start the task loop.
     *
     * @param {int} periodInMs the loop period in milliseconds
     */
    start(periodInMs) {
        if (this._isStarted)
            return;
        this._isStarted = true;
        this._runLoop(periodInMs);
    }
    /**
     * Stop the task loop.
     */
    stop() {
        if (!this._isStarted)
            throw new Error("Cannot stop TaskLooper because it's not started");
        this._isStarted = false;
        clearTimeout(this._timeout);
        this._timeout = undefined;
    }
    async _runLoop(periodInMs) {
        this._isLooping = true;
        while (this._isStarted) {
            const startTime = Date.now();
            await this._fn();
            if (this._isStarted)
                await new Promise((resolve) => { this._timeout = setTimeout(resolve, periodInMs - (Date.now() - startTime)); });
        }
        this._isLooping = false;
    }
}
exports.default = TaskLooper;
//# sourceMappingURL=TaskLooper.js.map