agtic/keycloak_theme
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Remove eventEmitter warning

Browse Source
This commit is contained in:
garronej 2023-03-18 19:02:17 +01:00
parent 16d18f23a1
commit 2eccc86e83
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/bin/tools/downloadAndUnzip.ts
View File

@ -130,6 +130,7 @@ async function unzip(zipFile: string, dir: string, archiveDir?: string): Promise
// Pull the file out of the archive, write it to the target directory // Pull the file out of the archive, write it to the target directory
const input = createRecordReadStream(); const input = createRecordReadStream();
const output = createWriteStream(filePath); const output = createWriteStream(filePath);
output.setMaxListeners(Infinity);
output.on("error", e => reject(Object.assign(e, { filePath }))); output.on("error", e => reject(Object.assign(e, { filePath })));
output.on("finish", () => resolve(filePath)); output.on("finish", () => resolve(filePath));
input.pipe(output); input.pipe(output);
@ -166,6 +167,7 @@ async function readFileChunk(file: string, start: number, end: number): Promise<
const chunks: Buffer[] = []; const chunks: Buffer[] = [];
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
const stream = createReadStream(file, { start, end }); const stream = createReadStream(file, { start, end });
stream.setMaxListeners(Infinity);
stream.on("error", e => reject(e)); stream.on("error", e => reject(e));
stream.on("end", () => resolve(Buffer.concat(chunks))); stream.on("end", () => resolve(Buffer.concat(chunks)));
stream.on("data", chunk => chunks.push(chunk as Buffer)); stream.on("data", chunk => chunks.push(chunk as Buffer));