queue.ts

export function createQueue(options?: Partial<{ maxItems?: number, noRun?: boolean }>) {
    const queue: QueueAction[] = []
    let isPendingAction = false
    const maxItems = options?.maxItems

    return {
        async enqueue(action: QueueAction) {
            if (maxItems && queue.length === maxItems) {
                queue.shift() // throw away
            }
            queue.push(action)
            if (options?.noRun) {
                return
            }
            await this.run()
        },
        async run() {        
            if (isPendingAction) {
                return
            }

            try {
                isPendingAction = true

                while (queue.length > 0) {
                    const action = queue.shift()
                    if (!action) {
                        break
                    }

                    await action()
                }

            } catch (e) {
                console.error({ e })
            } finally {
                isPendingAction = false
            }
        }
    }
}