Skip to content
This repository has been archived by the owner on Mar 30, 2018. It is now read-only.

Commit

Permalink
linter fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
stipsan committed Jun 18, 2016
1 parent 9474932 commit 4fe73d8
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/watchers.js
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}
Expand Down

0 comments on commit 4fe73d8

Please sign in to comment.