From da950e66ce93c3f1a54913f5995eadffffb398b7 Mon Sep 17 00:00:00 2001 From: Federico Zivolo <5382443+FezVrasta@users.noreply.github.com> Date: Thu, 3 Feb 2022 13:34:18 +0100 Subject: [PATCH] feat: expose thread --- promise-pool.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/promise-pool.js b/promise-pool.js index 18703a9..3afc1da 100644 --- a/promise-pool.js +++ b/promise-pool.js @@ -20,9 +20,9 @@ function promisePool({max_parallel, next_promise, next_promise_data, threads, pr } let next if (self.last_started) next = null - else if (promises_generator.next) next = promises_generator.next({ index: self.started, data: self.next_promise_data }).value + else if (promises_generator.next) next = promises_generator.next({ index: self.started, data: self.next_promise_data, thread }).value else if (Array.isArray(self.promises_generator)) next = self.promises_generator.shift() - else next = self.promises_generator({ index: self.started, data: self.next_promise_data }) + else next = self.promises_generator({ index: self.started, data: self.next_promise_data, thread }) if (next && next.then) { self.started += 1 //console.log('promise ' + JSON.stringify(context))