import {
  PromisuAll,
  PromisuMap,
  PromisuEvery,
  PromisuFew,
  PromisuFilter,
  PromisuFinally,
  PromisuQueue,
  PromisuRace,
  PromisuReduce,
  PromisuSome,
  PromisuTry,
  PromisuWaitFor,
  PromisuScan,
  PromisuDebounce,
  PromisuThrottle
} from 'promisu';
 
const asyncTask = (time) => () => { return new Promise(resolve => {
  setTimeout(() => resolve(time), time)
})};
 
const testPromisuQueue = () => new Promise(resolve => {
 
  // PromisuQueue
  console.log('// PromisuQueue');
 
  const promisuQueue = PromisuQueue.of({ concurrency: 1 });
 
  promisuQueue.add(asyncTask(1000), { priority: 1 }).then(() => {
    console.log('async task 1000 Done');
  });
 
  promisuQueue.addAll([asyncTask(2000), asyncTask(4000)], { priority: 2 }).then(() => {
    console.log('async task 2000/4000 Done');
    resolve()
  });
 
  promisuQueue.add(asyncTask(3000), { priority: 3 }).then(() => {
    console.log('async task 3000 Done');
  });
 
  // async task 1000 Done
  // async task 3000 Done
  // async task 2000/4000 Done
 
})
 
const testPromisuAll = () => new Promise(resolve => {
 
  // PromisuAll
  console.log('// PromisuAll');
 
  PromisuAll([asyncTask(2000), asyncTask(4000)], { concurrency: 2 })
    .then((result) => {
      console.log('PromisuAll done', result);
      resolve()
    })
 
  // PromisuAll done [ 2000, 4000 ]
 
})
 
const testPromisuRace = () => new Promise(resolve => {
 
  // PromisuRace
  console.log('// PromisuRace');
 
  PromisuRace([asyncTask(2000)(), asyncTask(1000)()])
    .then((result) => {
      console.log('PromisuRace done', result);
      resolve()
    })
 
  // PromisuRace done 1000
 
})
 
const testPromisuEvery = () => new Promise(resolve => {
 
  // PromisuEvery
  console.log('// PromisuEvery');
 
  const testFn = x => x > 1000;
 
  PromisuEvery([asyncTask(2000)(), 3000], testFn)
    .then((result) => {
      console.log('PromisuEvery done', result);
      resolve()
    })
 
  // PromisuEvery done true
 
})
 
const testPromisuSome = () => new Promise(resolve => {
 
  // PromisuSome
  console.log('// PromisuSome');
 
  const testFn = x => x > 2000;
 
  PromisuSome([asyncTask(2000)(), 3000], testFn)
    .then((result) => {
      console.log('PromisuSome done', result);
      resolve()
    })
 
  // PromisuSome done true
 
})
 
const testPromisuFew = () => new Promise(resolve => {
 
  // PromisuFew
  console.log('// PromisuFew');
 
  PromisuFew([asyncTask(2000)(), 3000, asyncTask(1000)()], { count: 2 })
    .then((result) => {
      console.log('PromisuFew done', result);
      resolve()
    })
 
  // PromisuFew done [ 3000, 1000 ]
 
})
 
const testPromisuMap = () => new Promise(resolve => {
 
  // PromisuMap
  console.log('// PromisuMap');
 
  const mapFn = x => new Promise(resolve => { resolve(x + 1) })
 
  PromisuMap([asyncTask(2000)(), 3000, asyncTask(1000)()], mapFn, { concurrency: 2 })
    .then((result) => {
      console.log('PromisuMap done', result);
      resolve()
    })
 
  // PromisuMap done [ 2001, 3001, 1001 ]
 
})
 
const testPromisuFilter = () => new Promise(resolve => {
 
  // PromisuFilter
  console.log('// PromisuFilter');
 
  const filterFn = x => new Promise(resolve => { resolve(x > 1000) })
 
  PromisuFilter([asyncTask(2000)(), 3000, asyncTask(1000)()], filterFn, { concurrency: 2 })
    .then((result) => {
      console.log('PromisuFilter done', result);
      resolve()
    })
 
  // PromisuFilter done [ 2000, 3000 ]
 
})
 
const testPromisuReduce = () => new Promise(resolve => {
 
  // PromisuReduce
  console.log('// PromisuReduce');
 
  const reduceFn = (acc, curr) => new Promise(resolve => { resolve(acc + curr) })
 
  PromisuReduce([asyncTask(2000)(), 3000, asyncTask(1000)()], reduceFn, 0)
    .then((result) => {
      console.log('PromisuReduce done', result);
      resolve()
    })
 
  // PromisuReduce done 6000
 
})
 
const testPromisuScan = () => new Promise(resolve => {
 
  // PromisuScan
  console.log('// PromisuScan');
 
  const scanFn = (acc, curr) => new Promise(resolve => { resolve(acc + curr) })
 
  PromisuScan([asyncTask(2000)(), 3000, asyncTask(1000)()], scanFn, 0)
    .then((result) => {
      console.log('PromisuScan done', result);
      resolve()
    })
 
  // PromisuScan done [ 0, 2000, 5000, 6000 ]
 
})
 
const testPromisuWaitFor = () => new Promise(resolve => {
 
  // PromisuWaitFor
  console.log('// PromisuWaitFor');
 
  const waitFn = x => () => new Promise(resolve => { resolve(x) })
 
  PromisuWaitFor(waitFn(true), 200)
    .then(() => {
      console.log('PromisuWaitFor done');
    })
 
  PromisuWaitFor(waitFn(false), 200)
    .catch(() => {
      // console.log('PromisuWaitFor done');
      resolve()
    })
 
  // PromisuWaitFor done
 
})
 
const testPromisuFinally = () => new Promise(resolve => {
 
  // PromisuFinally
  console.log('// PromisuFinally');
 
  // TODO
  resolve()
 
})
 
const testPromisuTry = () => new Promise(resolve => {
 
  // PromisuTry
  console.log('// PromisuTry');
 
  // TODO
  resolve()
 
})
 
const testPromisuDebounce = () => new Promise(resolve => {
 
  // PromisuDebounce
  console.log('// PromisuDebounce');
 
  // TODO
  resolve()
 
})
 
const testPromisuThrottle = () => new Promise(resolve => {
 
  // PromisuThrottle
  console.log('// PromisuThrottle');
 
  // TODO
  resolve()
 
})
 
const testArr = [
  testPromisuQueue,
  testPromisuAll,
  testPromisuRace,
  testPromisuEvery,
  testPromisuSome,
  testPromisuFew,
  testPromisuMap,
  testPromisuFilter,
  testPromisuReduce,
  testPromisuScan,
  testPromisuWaitFor,
  testPromisuFinally,
  testPromisuTry,
  testPromisuDebounce,
  testPromisuThrottle
]
 
const run = async (testArr) => {
  for (let next of testArr) {
    await next()
  }
}
 
run(testArr)
 

import {
  PromisuAll,
  PromisuMap,
  PromisuEvery,
  PromisuFew,
  PromisuFilter,
  PromisuFinally,
  PromisuQueue,
  PromisuRace,
  PromisuReduce,
  PromisuSome,
  PromisuTry,
  PromisuWaitFor,
  PromisuScan,
  PromisuDebounce,
  PromisuThrottle
} from 'promisu';
// or
const {
  PromisuAll,
  PromisuMap,
  PromisuEvery,
  PromisuFew,
  PromisuFilter,
  PromisuFinally,
  PromisuQueue,
  PromisuRace,
  PromisuReduce,
  PromisuSome,
  PromisuTry,
  PromisuWaitFor,
  PromisuScan,
  PromisuDebounce,
  PromisuThrottle 
} = require('promisu');