use fast-list

README.md

@@ -13,7 +13,7 @@ A library for turning push-based collections like streams into pull-based ones t
 
 * Buffers pushed and pulled values
 * Well-typed with TypeScript
-* Lightweight, no dependencies
+* [Lightweight], fast
 * Full test coverage
 
 ## Explanation
@@ -113,3 +113,4 @@ To make TypeScript know about the asnyc iterable types (`AsyncIterable<T>`, `Asy
 [callback-to-async-iterator]: https://github.com/withspectrum/callback-to-async-iterator
 [async]: http://2ality.com/2016/10/asynchronous-iteration.html
 [options]: https://www.typescriptlang.org/docs/handbook/compiler-options.html
+[lightweight]: https://bundlephobia.com/result?p=queueable

package.json

@@ -122,11 +122,15 @@
     "tslint-config-slikts": "^2.0.2",
     "typedoc": "^0.12.0",
     "typescript": "^3.0.1",
-    "validate-commit-msg": "^2.12.2"
+    "validate-commit-msg": "^2.12.2",
+    "@types/fast-list": "^1.0.0"
   },
   "husky": {
     "hooks": {
       "pre-commit": "lint-staged"
     }
+  },
+  "dependencies": {
+    "fast-list": "^1.0.3"
   }
 }

src/Balancer.ts

@@ -62,7 +62,7 @@ export default class Balancer<A> implements AsyncIterableIterator<A> {
     };
     this.resolverQueue.dequeueDefault(
       resolve => resolve(result),
-      () => void this.resultQueue.push(result),
+      () => void this.resultQueue.enqueue(result),
     );
   }
 
@@ -83,8 +83,8 @@ export default class Balancer<A> implements AsyncIterableIterator<A> {
     if (!this.closed) {
       this.closed = true;
       // Clear the queues
-      this.resultQueue.length = 0;
-      this.resolverQueue.length = 0;
+      this.resultQueue.clear();
+      this.resolverQueue.clear();
     }
     return {
       done: true,

src/Queue.ts

@@ -1,14 +1,23 @@
+import * as FastList from 'fast-list';
+
+// prevents rollup Error: Cannot call a namespace
+const fastList = FastList;
+
 /**
  * First-in, first-out (FIFO) buffer (queue) with default item values.
  */
-export default class Queue<A> extends Array<A> {
+export default class Queue<A> {
+  private list: FastList.List<A>;
+  constructor() {
+    this.list = fastList();
+  }
   /**
    * Add an item to the end of the queue.
    *
-   * @param a Item to be enqueued
+   * @param value Item to be enqueued
    */
-  enqueue(a: A) {
-    this.push(a);
+  enqueue(value: A) {
+    this.list.push(value);
   }
 
   /**
@@ -19,9 +28,13 @@ export default class Queue<A> extends Array<A> {
    * @param init Callback for making the default value
    */
   dequeueDefault<B>(handle: (a: A) => B, init: () => B): B {
-    if (this.length) {
-      return handle(this.shift() as A);
+    if (!this.list.length) {
+      return init();
     }
-    return init();
+    return handle(this.list.shift() as A);
+  }
+
+  clear() {
+    this.list.drop();
   }
 }