(filesize, n, totalOps)
| 86 | } |
| 87 | |
| 88 | function benchIter(filesize, n, totalOps) { |
| 89 | const fsp = require('fs/promises'); |
| 90 | const { pipeTo } = require('stream/iter'); |
| 91 | |
| 92 | async function run() { |
| 93 | const fh = await fsp.open(filename, 'r'); |
| 94 | await pipeTo(fh.pull(), { write() {} }); |
| 95 | await fh.close(); |
| 96 | } |
| 97 | |
| 98 | (async () => { |
| 99 | // Warmup |
| 100 | await run(); |
| 101 | |
| 102 | bench.start(); |
| 103 | for (let i = 0; i < n; i++) await run(); |
| 104 | fs.unlinkSync(filename); |
| 105 | bench.end(totalOps); |
| 106 | })(); |
| 107 | } |