web-stream-tools

import * as stream from '@openpgp/web-stream-tools'; // Imagine an encryptor API with process and finish methods class Encryptor { process(chunk) { console.log('Processing chunk:', chunk.byteLength, 'bytes'); // Simulate encryption, return a new Uint8Array return new Uint8Array(chunk.map(b => b ^ 0xFF)); } finish() { console.log('Finishing encryption.'); // Return any final encrypted bytes, or an empty Uint8Array return new Uint8Array([0xDE, 0xAD, 0xBE, 0xEF]); } } async function encryptDataStream() { const encryptor = new new Encryptor(); const inputData = new TextEncoder().encode("This is a test string to be encrypted using web-stream-tools."); // Create a ReadableStream from the input data const input = new ReadableStream({ start(controller) { controller.enqueue(inputData); controller.close(); } }); const encryptedStream = stream.transform(input, function process(chunk) { return encryptor.process(chunk); }, function finish() { return encryptor.finish(); }); // Read the encrypted stream to the end and collect all chunks const reader = encryptedStream.getReader(); let allChunks = []; while (true) { const { done, value } = await reader.read(); if (done) { break; } allChunks.push(value); } const finalEncryptedData = new Uint8Array(allChunks.reduce((acc, chunk) => acc.concat(Array.from(chunk)), [])); console.log('Total encrypted data length:', finalEncryptedData.byteLength, 'bytes'); console.log('Encryption complete.'); } encryptDataStream().catch(console.error);