mobiletto-base
Advanced tools
Comparing version 2.0.19 to 2.0.20
@@ -274,3 +274,3 @@ "use strict"; | ||
}), | ||
destroy: (client) => () => { | ||
destroy: (client) => () => __awaiter(void 0, void 0, void 0, function* () { | ||
const cache = client.getCache(); | ||
@@ -281,5 +281,7 @@ if (cache) { | ||
if (client.queueWorkers) { | ||
client.queueWorkers.forEach((w) => w.close(true)); | ||
const workerClosePromises = []; | ||
client.queueWorkers.forEach((w) => workerClosePromises.push(w.close(true))); | ||
yield Promise.all(workerClosePromises); | ||
} | ||
}, | ||
}), | ||
}; | ||
@@ -286,0 +288,0 @@ const CACHE_FUNCTIONS = { |
@@ -18,3 +18,5 @@ "use strict"; | ||
yield (0, redis_js_1.teardown)(); | ||
mobiletto_1.ALL_META_WORKERS.forEach((w) => w.close(true)); | ||
const workerClosePromises = []; | ||
mobiletto_1.ALL_META_WORKERS.forEach((w) => workerClosePromises.push(w.close(true))); | ||
yield Promise.all(workerClosePromises); | ||
}); | ||
@@ -21,0 +23,0 @@ exports.shutdownMobiletto = shutdownMobiletto; |
@@ -30,3 +30,3 @@ /// <reference types="node" /> | ||
driver_remove: (path: string, recursive?: boolean, quiet?: boolean) => Promise<string | string[]>; | ||
destroy: () => void; | ||
destroy: () => Promise<void>; | ||
}; |
@@ -267,3 +267,3 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { | ||
}), | ||
destroy: (client) => () => { | ||
destroy: (client) => () => __awaiter(void 0, void 0, void 0, function* () { | ||
const cache = client.getCache(); | ||
@@ -274,5 +274,7 @@ if (cache) { | ||
if (client.queueWorkers) { | ||
client.queueWorkers.forEach((w) => w.close(true)); | ||
const workerClosePromises = []; | ||
client.queueWorkers.forEach((w) => workerClosePromises.push(w.close(true))); | ||
yield Promise.all(workerClosePromises); | ||
} | ||
}, | ||
}), | ||
}; | ||
@@ -279,0 +281,0 @@ const CACHE_FUNCTIONS = { |
@@ -15,3 +15,5 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { | ||
yield teardown(); | ||
ALL_META_WORKERS.forEach((w) => w.close(true)); | ||
const workerClosePromises = []; | ||
ALL_META_WORKERS.forEach((w) => workerClosePromises.push(w.close(true))); | ||
yield Promise.all(workerClosePromises); | ||
}); | ||
@@ -18,0 +20,0 @@ export const ALL_DRIVERS = {}; |
@@ -30,3 +30,3 @@ /// <reference types="node" /> | ||
driver_remove: (path: string, recursive?: boolean, quiet?: boolean) => Promise<string | string[]>; | ||
destroy: () => void; | ||
destroy: () => Promise<void>; | ||
}; |
{ | ||
"name": "mobiletto-base", | ||
"version": "2.0.19", | ||
"version": "2.0.20", | ||
"type": "module", | ||
@@ -5,0 +5,0 @@ "description": "A storage layer that presents a uniform interface to Amazon S3, Backblaze B2, local and other storage systems.", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
157289
2973