Fix threads array

joshmgross/chunked-upload-testing
Josh Gross 5 years ago
parent 73a15dc5a9
commit 16019b42a9

@ -1623,7 +1623,7 @@ function uploadFile(restClient, cacheId, archivePath) {
const responses = [];
const fd = fs.openSync(archivePath, "r"); // Use the same fd for serial reads? Will this work for parallel too?
const concurrency = 4; // # of HTTP requests in parallel
const threads = new Array(concurrency);
const threads = [...new Array(concurrency).keys()];
core.debug("Awaiting all uploads");
let offset = 0;
yield Promise.all(threads.map(() => __awaiter(this, void 0, void 0, function* () {

@ -1623,7 +1623,7 @@ function uploadFile(restClient, cacheId, archivePath) {
const responses = [];
const fd = fs.openSync(archivePath, "r"); // Use the same fd for serial reads? Will this work for parallel too?
const concurrency = 4; // # of HTTP requests in parallel
const threads = new Array(concurrency);
const threads = [...new Array(concurrency).keys()];
core.debug("Awaiting all uploads");
let offset = 0;
yield Promise.all(threads.map(() => __awaiter(this, void 0, void 0, function* () {

@ -182,7 +182,7 @@ async function uploadFile(restClient: RestClient, cacheId: number, archivePath:
const fd = fs.openSync(archivePath, "r"); // Use the same fd for serial reads? Will this work for parallel too?
const concurrency = 4; // # of HTTP requests in parallel
const threads = new Array(concurrency);
const threads = [...new Array(concurrency).keys()];
core.debug("Awaiting all uploads");
let offset = 0;
await Promise.all(threads.map(async () => { // This might not work cause something something closures

Loading…
Cancel
Save