]> git.immae.eu Git - github/Chocobozzz/PeerTube.git/commitdiff
Remove useless use of async.each
authorChocobozzz <florian.bigard@gmail.com>
Tue, 14 Jun 2016 18:14:17 +0000 (20:14 +0200)
committerChocobozzz <florian.bigard@gmail.com>
Tue, 14 Jun 2016 18:14:17 +0000 (20:14 +0200)
server/lib/requestsScheduler.js

index 3c1df5d5c6b61b678cbfeb956c10ac3785352fa4..78570209d68be067a068fa6902496fdee114a040 100644 (file)
@@ -152,7 +152,7 @@ function makeRequests () {
     }
 
     // For each requests to make, we add it to the correct request type
-    async.each(requests, function (poolRequest, callbackEach) {
+    requests.forEach(function (poolRequest) {
       if (REQUEST_SCHEDULER_TYPE.indexOf(poolRequest.type) > -1) {
         const requestTypeToMake = requestsToMake[poolRequest.type]
         requestTypeToMake.requests.push(poolRequest.request)
@@ -161,22 +161,20 @@ function makeRequests () {
         logger.error('Unkown request type.', { request_type: poolRequest.type })
         return // abort
       }
+    })
 
-      callbackEach()
-    }, function () {
-      for (let type of Object.keys(requestsToMake)) {
-        const requestTypeToMake = requestsToMake[type]
-        // If there are requests for this type
-        if (requestTypeToMake.requests.length !== 0) {
-          makeRequest(type, requestTypeToMake.requests, function (err) {
-            if (err) logger.error('Errors when sent ' + type + ' requests.', { error: err })
-
-            // We made the requests, so we can remove them from the scheduler
-            Requests.removeRequests(requestTypeToMake.ids)
-          })
-        }
+    for (let type of Object.keys(requestsToMake)) {
+      const requestTypeToMake = requestsToMake[type]
+      // If there are requests for this type
+      if (requestTypeToMake.requests.length !== 0) {
+        makeRequest(type, requestTypeToMake.requests, function (err) {
+          if (err) logger.error('Errors when sent ' + type + ' requests.', { error: err })
+
+          // We made the requests, so we can remove them from the scheduler
+          Requests.removeRequests(requestTypeToMake.ids)
+        })
       }
-    })
+    }
   })
 }