Stream Beans Performance Testing

StreamBeans-test1.js

const Benchmark         = require('benchmark');
const {PassThrough}     = require("stream");
const createStreamBeans = require("streambeans").createStreamBeans;

const suite = new Benchmark.Suite();

const inStreamBeans  = new PassThrough();
const outStreamBeans = new PassThrough();

const inStreamNoBeans  = new PassThrough();
const outStreamNoBeans = new PassThrough();

const beans = createStreamBeans(inStreamBeans, outStreamBeans);
inStreamNoBeans.pipe(outStreamNoBeans);

function withoutBeansCallback(d) {
    outStreamNoBeans.once("data", () => d.resolve());
    inStreamNoBeans.write("0");
}

function withBeansCallback(d) {
    outStreamBeans.once("data", () => d.resolve());
    inStreamBeans.write("0");
}

// add tests
suite
    .add('Without StreamBeans', withoutBeansCallback, {defer: true})
    .add('With StreamBeans', withBeansCallback, {defer: true})
    // add listeners
    .on('cycle', function (event) {
        console.log(String(event.target));
    })
    .on('complete', function () {
        console.log('Fastest is ' + this.filter('fastest').map('name'));
    })
    // run async
    .run({async: true});