node-web-stream-adapters

import fs from "fs/promises"; import { createReadableStreamFromBuffer } from "node-web-stream-adapters"; async function processFileAsStream() { try { const filePath = 'some-file.txt'; // Assume 'some-file.txt' exists and has content. // In a real scenario, you might read a large file or network response. const buffer = await fs.readFile(filePath); const webStream = createReadableStreamFromBuffer(buffer); console.log('Created Web ReadableStream from buffer.'); // Example: Consume the web stream (e.g., pipe to another writable stream or process chunks) const reader = webStream.getReader(); while (true) { const { done, value } = await reader.read(); if (done) { console.log('Stream finished.'); break; } console.log('Received chunk:', new TextDecoder().decode(value)); } } catch (error) { console.error('Error processing stream:', error); } } // Create a dummy file for the example to run async function setupDummyFile() { const content = 'Hello, Web Streams!\nThis is a test file.'; await fs.writeFile('some-file.txt', content); console.log('Dummy file created: some-file.txt'); await processFileAsStream(); } setupDummyFile();