modern-tar

import { createTarPacker, createTarDecoder } from 'modern-tar'; async function processTarStream() { // Create a tar packer const { readable, controller } = createTarPacker(); // Add entries dynamically const fileStream = controller.add({ name: "dynamic.txt", size: 5, type: "file" }); // Write content to the stream const writer = fileStream.getWriter(); await writer.write(new TextEncoder().encode("hello")); await writer.close(); // Add another entry, maybe a directory controller.add({ name: "my-dir/", type: "directory", size: 0 }); // When done adding entries, finalize the archive controller.finalize(); // Pipe the archive right into a decoder const decodedStream = readable.pipeThrough(createTarDecoder()); for await (const entry of decodedStream) { console.log(`Decoded: ${entry.header.name}`); const shouldSkip = entry.header.name.endsWith(".md"); if (shouldSkip) { // You MUST drain the body with cancel() to proceed to the next entry or read it fully, // otherwise the stream will stall. await entry.body.cancel(); continue; } // Example: Read the content for non-skipped files if (entry.header.type === 'file') { const reader = entry.body.getReader(); let chunk = ''; while (true) { const { done, value } = await reader.read(); if (done) break; chunk += new TextDecoder().decode(value); } console.log(`Content of ${entry.header.name}: ${chunk}`); } } console.log('Tar stream processing complete.'); } processTarStream().catch(console.error);