/
githubmirror
/
node
Обзор
Документация
Войти
/
githubmirror
/
node
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
benchmark/streams/writable-manywrites.js
46 строк
929 B
Robert Nagy
stream: writable state bitmap
29 сен 2023, 21:13
Не верифицирован
29 сен 2023, 21:13
53b5545
Код
Авторство
О чём код?
'use strict'; const common = require('../common'); const Writable = require('stream').Writable; const bench = common.createBenchmark(main, { n: [1e5], sync: ['yes', 'no'], writev: ['yes', 'no'], callback: ['yes', 'no'], len: [1024, 32 * 1024], }); function main({ n, sync, writev, callback, len }) { const b = Buffer.allocUnsafe(len); const s = new Writable({ highWaterMark: 16 * 1024 }); sync = sync === 'yes'; const writecb = (cb) => { if (sync) cb(); else process.nextTick(cb); }; if (writev === 'yes') { s._writev = (chunks, cb) => writecb(cb); } else { s._write = (chunk, encoding, cb) => writecb(cb); } const cb = callback === 'yes' ? () => {} : null; bench.start(); let k = 0; function run() { while (k++ < n && s.write(b, cb)); if (k >= n) { bench.end(n); s.removeListener('drain', run); } } s.on('drain', run); run(); }