add blobStore.close()

digidem · Oct 29, 2024 · b847084 · b847084
1 parent 81c9253
commit b847084
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/src/blob-store/index.js b/src/blob-store/index.js
@@ -242,6 +242,11 @@ export class BlobStore extends TypedEmitter {
 
     return drive.clear(path, options)
   }
+
+  close() {
+    this.#downloader.removeAllListeners()
+    this.#downloader.destroy()
+  }
 }
 
 // Don't want to export the class, but do want to export the type.

diff --git a/src/mapeo-project.js b/src/mapeo-project.js
@@ -442,6 +442,7 @@ export class MapeoProject extends TypedEmitter {
    */
   async close() {
     this.#l.log('closing project %h', this.#projectId)
+    this.#blobStore.close()
     const dataStorePromises = []
     for (const dataStore of Object.values(this.#dataStores)) {
       dataStorePromises.push(dataStore.close())