minizlib

import { BrotliDecompress } from 'minizlib'; import { Readable, Writable } from 'stream'; // Node.js built-in streams for simulation // Simulate a source of compressed data using a custom Readable stream class CompressedDataSource extends Readable { private chunks: Buffer[]; constructor(data: Buffer) { super(); this.chunks = [data]; // In a real app, 'data' would be actual compressed content } _read() { if (this.chunks.length > 0) { this.push(this.chunks.shift()); } else { this.push(null); // Signal end of stream } } } // Simulate a destination for decoded data using a custom Writable stream class DecodedDataDestination extends Writable { private receivedData: Buffer[] = []; constructor() { super(); } _write(chunk: Buffer, encoding: string, callback: (error?: Error | null) => void) { this.receivedData.push(chunk); callback(); } getData(): Buffer { return Buffer.concat(this.receivedData); } } async function runDecompression() { // For demonstration, we use a simple Brotli-compressed hex string. // In a real application, this would come from a file, network, etc. // Note: minizlib doesn't provide direct buffer compression, so this input is pre-compressed. const compressedBrotliHex = 'C323040B001402000000A1302A0B50616464656420546869732069732073616D706C65206461746120746F20626520636F6D7072657373656420616E64207468656E206465636F6D70726573736564207573696E67206D696E697A6C69622E'; const mockCompressedBuffer = Buffer.from(compressedBrotliHex, 'hex'); const inputSource = new CompressedDataSource(mockCompressedBuffer); const decompressStream = new BrotliDecompress(); const outputDestination = new DecodedDataDestination(); await new Promise<void>((resolve, reject) => { inputSource.pipe(decompressStream).pipe(outputDestination) .on('finish', () => { console.log('Decompression finished successfully.'); console.log('Decoded data:', outputDestination.getData().toString('utf8')); resolve(); }) .on('error', (err) => { console.error('Decompression error:', err); reject(err); }); }); } runDecompression().catch(console.error);