update deps

benchmarks/multi-core-indexer.js

@@ -24,7 +24,7 @@ nanobench('Index 20 cores of 1000 blocks (10 times)', async (b) => {
         await new Promise((res) => setTimeout(res, 10))
       },
       maxBatch: 500,
-      storage: () => ram(),
+      storage: () => new ram(),
     })
     await throttledIdle(indexer)
     assert(count === expected.length)

benchmarks/multifeed-index.js

@@ -12,7 +12,7 @@ nanobench('Index 20 cores of 1000 blocks (10 times)', async (b) => {
   const storages = new Map()
 
   function createStorage(key) {
-    const storage = storages.get(key) || ram()
+    const storage = storages.get(key) || new ram()
     storages.set(key, storage)
     return storage
   }

index.js

@@ -162,7 +162,7 @@ class MultiCoreIndexer extends TypedEmitter {
     if (typeof storage !== 'string') return storage
     const directory = storage
     return function createFile(name) {
-      return raf(name, { directory })
+      return new raf(name, { directory })
     }
   }
 }

lib/core-index-stream.js

@@ -134,6 +134,13 @@ class CoreIndexStream extends Readable {
           (await this[kPushEntry](index)) ||
           /* istanbul ignore next - TODO: Test when hypercore-next supports a core.clear() method */
           didPush
+        // This is for back-pressure, for which there is not a good test yet.
+        // The faster streamx state machine in https://github.com/mafintosh/streamx/pull/77
+        // caused this stream's read buffer to never fill with the current tests,
+        // so that this line is currently uncovered by tests.
+        // TODO: Add a test similar to 'Appends from a replicated core are indexed' in core-index-stream.test.js
+        // but pipe to a slow stream, to test back-pressure, which should result in coverage of this line.
+        /* istanbul ignore next */
         if (!this.#readBufferAvailable) break
       }
     }