Проблема во время тестирования transform-streams (Node.js) с Benchmark.js - PullRequest
Новая
       30

Проблема во время тестирования transform-streams (Node.js) с Benchmark.js

0 голосов
/ 05 декабря 2018

Я пытаюсь протестировать код NodeJS, но получаю следующую ошибку: 

    events.js:167
    throw er; // Unhandled 'error' event
    ^

    Error [ERR_STREAM_WRITE_AFTER_END]: write after end
    at writeAfterEnd (_stream_writable.js:243:12)
    at Transform.Writable.write (_stream_writable.js:291:5)
    at ReadStream.ondata (_stream_readable.js:666:20)
    at ReadStream.emit (events.js:182:13)
    at addChunk (_stream_readable.js:283:12)
    at readableAddChunk (_stream_readable.js:264:11)
    at ReadStream.Readable.push (_stream_readable.js:219:10)
    at lazyFs.read (internal/fs/streams.js:181:12)
    at FSReqWrap.wrapper [as oncomplete] (fs.js:460:17)

    Emitted 'error' event at:
    at Transform.onerror (_stream_readable.js:690:12)
    at Transform.emit (events.js:182:13)
    at writeAfterEnd (_stream_writable.js:245:10)
    at Transform.Writable.write (_stream_writable.js:291:5)
    [... lines matching original stack trace ...]
    at lazyFs.read (internal/fs/streams.js:181:12)

Мой код работает автономно, но не с Benchmark.js.В чем проблема?Кажется, что когда Benchmark.js запускает второй тест, он пытается записать в закрытый файл, но я не вижу проблемы. 

    const Benchmark = require('benchmark');
    const suite = new Benchmark.Suite;
    const fs = require('fs');
    const stream = require('stream');

    const uppercaser = new stream.Transform({
        transform: function (chunk, _, callback) {
            callback(null, chunk.toString().toUpperCase());
       }
    });

    suite.add('transform-streams', {
       defer: true,
       fn: function (deferred) {

            const readStream = fs.createReadStream('1.txt', {
               highWaterMark: 1024
            });
            const writeStream = fs.createWriteStream('write1.txt');

            readStream
               .pipe(uppercaser)
               .pipe(writeStream).on('finish', () => {
                   deferred.resolve();
                });
         }
    })
    .on('cycle', function (event) {
        console.log(String(event.target));
    }).on('complete', function () {
        console.log(this[0].stats)
    }).run()

1 Ответ

0 голосов
/ 06 декабря 2018

Вам просто нужно переместиться в функцию uppercaser внутри fn prop файла suite.add, например: 

suite.add('transform-streams', {
   defer: true,
   fn: function (deferred) {

       const uppercaser = new stream.Transform({
         transform: function (chunk, _, callback) {
           callback(null, chunk.toString().toUpperCase());
         }
       });

        const readStream = fs.createReadStream('1.txt', {
           highWaterMark: 1024
        });
        const writeStream = fs.createWriteStream('write1.txt');

        readStream
           .pipe(uppercaser)
           .pipe(writeStream).on('finish', () => {
               deferred.resolve();
            });
     }
})
.on('cycle', function (event) {
    console.log(String(event.target));
}).on('complete', function () {
    console.log(this[0].stats)
}).run()
...