0.3.0

CHANGELOG.md

@@ -2,6 +2,10 @@
 
 # Upcoming
 
+# v0.3.0
+
+Date: 2024-04-21T22:11:04.415Z
+
 - Performance: Better handling of wait timeouts. Instead of waiting in intervals of 50ms, we check the result whenever new results are
   added to the bin.
 - Feature: "clear" method to remove all objects

dist/QueryBin.cjs

@@ -3,11 +3,14 @@
 class QueryBin {
   constructor(
     queries = {},
-    { retryDelayMillis = 50, timeoutMillis = 1000 } = {},
+    { retryDelayMillis = 200, timeoutMillis = 1000 } = {},
   ) {
     this.values = [];
     this.retryDelayMillis = retryDelayMillis;
     this.timeoutMillis = timeoutMillis;
+
+    this.latch = new Latch();
+
     this.queryAll = mapValues(queries, (factory) => {
       return (...args) => {
         const { queryAll } = factory(...args);
@@ -68,10 +71,16 @@ class QueryBin {
 
   add(value) {
     this.values.push(value);
+    this.latch.next();
   }
 
   addAll(values) {
     this.values.push(...values);
+    this.latch.next();
+  }
+
+  clear() {
+    this.values = [];
   }
 
   all() {
@@ -101,7 +110,8 @@ class QueryBin {
       try {
         return await fn();
       } catch (e) {
-        await delay(this.retryDelayMillis);
+        const remaining = this.timeoutMillis - (Date.now() - started);
+        await Promise.race([delay(remaining), this.latch.promise]);
       }
     }
     await fn();
@@ -120,4 +130,19 @@ function delay(ms) {
   return new Promise((resolve) => setTimeout(resolve, ms));
 }
 
+class Latch {
+  constructor() {
+    this.promise = new Promise((resolve) => {
+      this.open = resolve;
+    });
+  }
+
+  next() {
+    this.open();
+    this.promise = new Promise((resolve) => {
+      this.open = resolve;
+    });
+  }
+}
+
 exports.QueryBin = QueryBin;

package.json

@@ -1,6 +1,6 @@
 {
   "name": "query-bin",
-  "version": "0.2.1",
+  "version": "0.3.0",
   "description": "A list with queries like in the 'testing-library'",
   "types": "index.d.s",
   "type": "module",