actions
/
cache
mirror of https://github.com/actions/cache.git
3
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add missing await

Browse Source
joshmgross/chunked-upload-testing
Josh Gross 5 years ago
parent 289c5d2518
commit 14055801c2
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File

2
dist/restore/index.js vendored
Unescape Escape View File

@ -1626,7 +1626,7 @@ function uploadFile(restClient, cacheId, archivePath) {
const threads = new Array(concurrency); const threads = new Array(concurrency);
core.debug("Awaiting all uploads"); core.debug("Awaiting all uploads");
let offset = 0; let offset = 0;
Promise.all(threads.map(() => __awaiter(this, void 0, void 0, function* () { yield Promise.all(threads.map(() => __awaiter(this, void 0, void 0, function* () {
while (offset < fileSize) { while (offset < fileSize) {
const chunkSize = offset + MAX_CHUNK_SIZE > fileSize ? fileSize - offset : MAX_CHUNK_SIZE; const chunkSize = offset + MAX_CHUNK_SIZE > fileSize ? fileSize - offset : MAX_CHUNK_SIZE;
const start = offset; const start = offset;

2
dist/save/index.js vendored
Unescape Escape View File

@ -1626,7 +1626,7 @@ function uploadFile(restClient, cacheId, archivePath) {
const threads = new Array(concurrency); const threads = new Array(concurrency);
core.debug("Awaiting all uploads"); core.debug("Awaiting all uploads");
let offset = 0; let offset = 0;
Promise.all(threads.map(() => __awaiter(this, void 0, void 0, function* () { yield Promise.all(threads.map(() => __awaiter(this, void 0, void 0, function* () {
while (offset < fileSize) { while (offset < fileSize) {
const chunkSize = offset + MAX_CHUNK_SIZE > fileSize ? fileSize - offset : MAX_CHUNK_SIZE; const chunkSize = offset + MAX_CHUNK_SIZE > fileSize ? fileSize - offset : MAX_CHUNK_SIZE;
const start = offset; const start = offset;

2
src/cacheHttpClient.ts
Unescape Escape View File

@ -185,7 +185,7 @@ async function uploadFile(restClient: RestClient, cacheId: number, archivePath:
const threads = new Array(concurrency); const threads = new Array(concurrency);
core.debug("Awaiting all uploads"); core.debug("Awaiting all uploads");
let offset = 0; let offset = 0;
Promise.all(threads.map(async () => { // This might not work cause something something closures await Promise.all(threads.map(async () => { // This might not work cause something something closures
while (offset < fileSize) { while (offset < fileSize) {
const chunkSize = offset + MAX_CHUNK_SIZE > fileSize ? fileSize - offset : MAX_CHUNK_SIZE; const chunkSize = offset + MAX_CHUNK_SIZE > fileSize ? fileSize - offset : MAX_CHUNK_SIZE;
const start = offset; const start = offset;

Write Preview
Loading…
Cancel
Save