timeoutChain

timeoutChain.js

const timeoutChain = (fn, { ms } = { ms: 0 }) => {
    const timer = {
        id: null,
        unsubscribe(done = () => {}) {
            clearTimeout(this.id);
            this.isRunning = false;
            done();
        },
        isRunning: true,
    };

    function run() {
        timer.id = setTimeout(() => {
            fn(() => timer.unsubscribe());

            if (timer.isRunning) {
                run();
            }
        }, ms);
    }

    run();

    return (onDone) => () => timer.unsubscribe(onDone);
};