fix

.changeset/clean-pigs-guess.md

@@ -1,5 +1,5 @@
 ---
-"storage-box": minor
+"storage-box": patch
 ---
 
 fix: added `getall` to extract entry storage as a record/key-value object

package.json

@@ -1,6 +1,6 @@
 {
   "name": "storage-box",
-  "version": "1.0.0-canary.3",
+  "version": "1.0.0-canary.4",
   "description": "A memory-based key–value storage for javascript.",
   "type": "module",
   "main": "dist/index.cjs",

src/client.ts

@@ -19,14 +19,16 @@ class Client<Driver extends StorageDriver = MemoryDriver> implements StorageOper
   private readonly _drive: StorageDriver;
 
   private readonly _ttl: Map<HashField, TTL> = new Map();
-  private _state: StorageState = 'pending';
+  private _state: StorageState = 'stale';
 
   constructor(storage?: Driver) {
     this._drive = storage || new MemoryDriver();
     this._prepare().finally();
   }
 
   private async _prepare() {
+    this._state = 'pending';
+
     if (this._drive.prepare) {
       await this._drive.prepare();
     }
@@ -43,7 +45,10 @@ class Client<Driver extends StorageDriver = MemoryDriver> implements StorageOper
     // Wait til driver is ready
     return new Promise<void>((resolve) => {
       const intervalId = setInterval(() => {
-        if (this._state === 'ready') {
+        if (this._state === 'stale') {
+          this._state = 'pending';
+          this._prepare().finally();
+        } else if (this._state === 'ready') {
           clearInterval(intervalId);
           resolve();
         }

src/list.test.ts

@@ -28,6 +28,17 @@ describe('List', () => {
     expect(await list.toArray()).to.have.members([1, 2, 3]);
   });
 
+  it('Async iteration', async () => {
+    const list = c.createList();
+    await list.push(1);
+    await list.push(2);
+    await list.push(3);
+
+    for await (const item of list) {
+      expect(item).to.be.oneOf([1, 2, 3]);
+    }
+  });
+
   describe('Lucky Numbers', () => {
     const list = c.createList(LuckyNumberList);
 

src/list.ts

@@ -7,6 +7,15 @@ export class List<Value extends HashValue = HashValue> {
     private readonly _key: HashKey
   ) {}
 
+  [Symbol.asyncIterator]() {
+    const pList = this.list();
+    return (async function* (): AsyncGenerator<Value> {
+      for (const item of await pList) {
+        yield item;
+      }
+    })();
+  }
+
   set(index: number, value: Value | null): Promise<void> {
     return this._client.lset(this._key, index, value);
   }

src/typings.ts

@@ -69,7 +69,7 @@ export interface IStorageParser {
   parse(value: any): Map<string, Serializable>;
 }
 
-export type StorageState = 'pending' | 'ready';
+export type StorageState = 'stale' | 'pending' | 'ready';
 
 // ---------------------