123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354
import isCI from 'is-ci'
import { composeAsync } from './composeAsync'import { delay } from './delay'import { mapAsync } from './mapAsync'import { mapAsyncLimit } from './mapAsyncLimit'import { toDecimal } from './toDecimal'
jest.setTimeout(30000)
test('happy', async () => {  const limit = 3  const startTime = new Date().getTime()  const list = [ 1, 2, 3, 4, 5, 6, 7, 8, 9 ]  const iterable = async x => {    await delay(500)
    return x + 1  }  const result = await mapAsyncLimit(    iterable, limit, list  )  const endTime = new Date().getTime()  const diffTime = endTime - startTime
  const startTime2 = new Date().getTime()  await mapAsync(iterable, list)  const endTime2 = new Date().getTime()  const diffTime2 = endTime2 - startTime2
  const methodScale = toDecimal((diffTime2 - diffTime) / 1000, 0)  expect(result).toEqual([ 2, 3, 4, 5, 6, 7, 8, 9, 10 ])  if (!isCI) expect(methodScale).toBe(limit)})
const fn = async x => {  await delay(100)
  return x + 1}
test('with R.composeAsync', async () => {  const result = await composeAsync(mapAsyncLimit(fn, 2), x =>    x.map(xx => xx + 1))([ 1, 2, 3, 4, 5, 6 ])  expect(result).toEqual([ 3, 4, 5, 6, 7, 8 ])})
test('fallback to R.mapFastAsync', async () => {  const result = await mapAsyncLimit(    fn, 4, [ 1, 2, 3 ]  )  expect(result).toEqual([ 2, 3, 4 ])})