in packages/azure-kusto-ingest/src/fileDescriptor.ts [41:62]
async _gzip(): Promise<string> {
const { path, cleanup } = await tmpFile({ postfix: ".gz", keep: false });
this.cleanupTmp = cleanup;
const zipper = zlib.createGzip();
const input = fs.createReadStream(this.file as string, { autoClose: true });
const output = fs.createWriteStream(path);
await new Promise((resolve, reject) => {
input
.pipe(zipper)
.pipe(output)
.on("error", (err) => {
reject(err);
});
output.once("close", () => {
resolve(null);
});
});
return path;
}