Function fn

test/unit/shared/utils/async.spec.ts:122–130

(item: (typeof items)[number])

          let tooManyRunningTasksEncountered = false
          let currentlyRunning = 0
          const fn = async (item: (typeof items)[number]) => {
            currentlyRunning++
            if (currentlyRunning > concurrency) {
              tooManyRunningTasksEncountered = true
            }
            const task = s.schedule(Promise.resolve(item))
            task.then(() => currentlyRunning--) // this task always succeeds by construct
            return task
          }
          await s.waitFor(mapWithConcurrency(items, fn, concurrency))
          expect(tooManyRunningTasksEncountered).toBe(false)
        },