fix: avoid passing on an empty buffer in finish callback

walterra · Oct 30, 2023 · e0fbe8e · e0fbe8e
1 parent a70905f
commit e0fbe8e
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/src/_index-queue.js b/src/_index-queue.js
@@ -109,9 +109,14 @@ export default function indexQueueFactory({
       }
     },
     finish: () => {
-      ingest(buffer);
       finished = true;
-      buffer = [];
+
+      if (buffer.length > 0) {
+        ingest(buffer);
+        buffer = [];
+      } else if (queue.length === 0 && ingesting === 0) {
+        queueEmitter.emit('finish');
+      }
     },
     queueEmitter,
   };