Fix AsyncIterator.prototype.throttle

PR-URL: #424
metarhia · Apr 22, 2019 · e2db419 · e2db419
1 parent f3dd5c9
commit e2db419
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/lib/async-iterator.js b/lib/async-iterator.js
@@ -188,8 +188,8 @@ class AsyncIterator {
     return this;
   }
 
-  throttle(percent) {
-    return new ThrottleIterator(this, percent);
+  throttle(percent, min) {
+    return new ThrottleIterator(this, percent, min);
   }
 
   enumerate() {

diff --git a/test/fixtures/iterator.js b/test/fixtures/iterator.js
@@ -15,6 +15,13 @@ metatests.test('new AsyncIterator() on non Iterable', test => {
   test.end();
 });
 
+metatests.test('AsyncIterator.throttle with min value', test => {
+  const expectedMin = 1;
+  const { min } = asyncIter([]).throttle(1, expectedMin);
+  test.strictSame(min, expectedMin);
+  test.end();
+});
+
 metatests.test('new AsyncIterator() on AsyncIterable', test => {
   const iterator = array[Symbol.iterator]();
   const iterable = {