From 4fe73d897c665ea90ffdcdbe38977387a54fd291 Mon Sep 17 00:00:00 2001 From: Stian Didriksen Date: Sat, 18 Jun 2016 20:14:26 +0200 Subject: [PATCH] linter fixes --- src/watchers.js | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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) }