wip

Author: silesky

packages/signals/signals/src/core/buffer/index.ts

@@ -25,7 +25,7 @@ export class SignalStore implements SignalPersistentStorage {
   }
 
   constructor(settings: { maxBufferSize?: number } = {}) {
-    this.maxBufferSize = settings.maxBufferSize ?? 50
+    this.maxBufferSize = settings.maxBufferSize ?? 10
     this.db = this.initSignalDB()
   }
 
@@ -59,20 +59,20 @@ export class SignalStore implements SignalPersistentStorage {
     const transaction = db.transaction(SignalStore.STORE_NAME, 'readwrite')
     const store = transaction.objectStore(SignalStore.STORE_NAME)
     let count = await store.count()
-    if (count >= maxItems) {
+    if (count > maxItems) {
       const cursor = await store.openCursor()
       if (cursor) {
         // delete up to maxItems
         if (deleteMultiple) {
-          while (count >= maxItems) {
+          while (count > maxItems) {
             await cursor.delete()
             count--
             await cursor.continue()
           }
         } else {
           await cursor.delete()
         }
-        logger.debug('Deleted item', { count: count - 1, key: cursor.key })
+        logger.debug('Deleted item', { count: count, key: cursor.key })
       }
     }
     return await transaction.done