repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Convert function to arrow function in UT
[poolifier.git]
/
tests
/
test-utils.js
diff --git
a/tests/test-utils.js
b/tests/test-utils.js
index 4668e0720c7ea1c2eb9cca649f17bb7ade4eb826..e63e14f2987748d61030ad964588df864958f3a6 100644
(file)
--- a/
tests/test-utils.js
+++ b/
tests/test-utils.js
@@
-1,7
+1,7
@@
class TestUtils {
static async waitExits (pool, numberOfExitEventsToWait) {
let exitEvents = 0
class TestUtils {
static async waitExits (pool, numberOfExitEventsToWait) {
let exitEvents = 0
- return new Promise(
function (resolve, reject)
{
+ return new Promise(
resolve =>
{
pool.workers.forEach(w => {
w.on('exit', () => {
exitEvents++
pool.workers.forEach(w => {
w.on('exit', () => {
exitEvents++
@@
-17,9
+17,20
@@
class TestUtils {
return new Promise(resolve => setTimeout(resolve, ms))
}
return new Promise(resolve => setTimeout(resolve, ms))
}
- static async workerSleepFunction (data, ms) {
+ static async workerSleepFunction (
+ data,
+ ms,
+ rejection = false,
+ rejectionMessage = ''
+ ) {
return new Promise((resolve, reject) => {
return new Promise((resolve, reject) => {
- setTimeout(() => resolve(data), ms)
+ setTimeout(
+ () =>
+ rejection === true
+ ? reject(new Error(rejectionMessage))
+ : resolve(data),
+ ms
+ )
})
}
})
}
@@
-35,7
+46,7
@@
class TestUtils {
/**
* Intentionally inefficient implementation.
*
/**
* Intentionally inefficient implementation.
*
- * @param {
*
} n
+ * @param {
number
} n
* @returns {number}
*/
static fibonacci (n) {
* @returns {number}
*/
static fibonacci (n) {
@@
-46,7
+57,7
@@
class TestUtils {
/**
* Intentionally inefficient implementation.
*
/**
* Intentionally inefficient implementation.
*
- * @param {
*
} n
+ * @param {
number
} n
* @returns {number}
*/
static factorial (n) {
* @returns {number}
*/
static factorial (n) {