diff options
| author | Alex Early <alexander.early@gmail.com> | 2018-07-09 11:24:06 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-07-09 11:24:06 -0700 |
| commit | 1f3925eb5b97bad4da8d225eb61ce75c728d6760 (patch) | |
| tree | 229be5f072db9918cdd5eb8e3ba20f373a0eb45e /lib/internal/queue.js | |
| parent | 17471a579b0650e54b322120b1e6ca85de0846c5 (diff) | |
| download | async-1f3925eb5b97bad4da8d225eb61ce75c728d6760.tar.gz | |
feat: Iterable queues (#1556)
* feat: iterable queues
* docs
Diffstat (limited to 'lib/internal/queue.js')
| -rw-r--r-- | lib/internal/queue.js | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/lib/internal/queue.js b/lib/internal/queue.js index a811080..4c1f5cc 100644 --- a/lib/internal/queue.js +++ b/lib/internal/queue.js @@ -87,6 +87,9 @@ export default function queue(worker, concurrency, payload) { var isProcessing = false; var q = { _tasks: new DLL(), + *[Symbol.iterator] () { + yield* q._tasks[Symbol.iterator]() + }, concurrency, payload, saturated: noop, |