diff --git a/src/watchers.js b/src/watchers.js index 22d8a67..fcdaf79 100644 --- a/src/watchers.js +++ b/src/watchers.js @@ -13,14 +13,14 @@ export function *watchRemote(socket, event = 'dispatch') { } } -export function *watchRequests(socket, concurrency = 3, retries = 5) { +export function *watchRequests(socket, workers = 3, retries = 5) { const chan = yield call(channel) - for (let i = 0; i < concurrency; i++) { + for (let i = 0; i < workers; i++) { yield fork(processRequest, socket, chan, retries) } - while (true) { + while (true) { // eslint-disable-line const payload = yield take(REQUEST) yield put(chan, payload) }