speedometer

const speedometer = require('speedometer'); const fs = require('fs'); // Create a speedometer instance with a 10-second buffer const speed = speedometer(10); const stream = fs.createReadStream('/dev/urandom', { highWaterMark: 1024 * 1024 }); // Read in 1MB chunks let totalBytes = 0; let lastLogTime = Date.now(); stream.on('data', function(data) { // Pass the amount of bytes transferred to the speedometer const bytesPerSecond = speed(data.length); totalBytes += data.length; // Log speed every second if (Date.now() - lastLogTime >= 1000) { console.log(`Current speed: ${bytesPerSecond.toFixed(2)} bytes/second`); lastLogTime = Date.now(); } }); stream.on('end', () => { console.log(` Finished reading. Total bytes: ${totalBytes}`); const finalSpeed = speed(); // Get current speed one last time console.log(`Final calculated speed (over buffer): ${finalSpeed.toFixed(2)} bytes/second`); }); stream.on('error', (err) => { console.error('Stream error:', err); });