xz_compat_streaming_file_compression_decompression_quickstart.ts

1import { createCompressor, createDecompressor } from 'xz-compat';
2import { createReadStream, createWriteStream } from 'fs';
3import { pipeline } from 'stream/promises';
4
5async function runQuickstart() {
6  // Compress a file
7  const compressor = createCompressor();
8  await pipeline(
9    createReadStream('input.txt'),
10    compressor,
11    createWriteStream('input.txt.xz')
12  );
13
14  // Decompress a file
15  const decompressor = createDecompressor();
16  await pipeline(
17    createReadStream('input.txt.xz'),
18    decompressor,
19    createWriteStream('output.txt')
20  );
21
22  console.log('Compression and decompression completed successfully.');
23}
24
25runQuickstart().catch(console.error);