Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -23,13 +23,14 @@
var bench = require( '@stdlib/bench' );
var noop = require( '@stdlib/utils/noop' );
var nextTick = require( '@stdlib/utils/next-tick' );
var format = require( '@stdlib/string/format' );
var pkg = require( './../package.json' ).name;
var debugSinkStream = require( './../lib' );


// MAIN //

bench( pkg+'::throughput,baseline', function benchmark( b ) {
bench( format( '%s::throughput,baseline', pkg ), function benchmark( b ) {
var i;

i = 0;
Expand All @@ -55,7 +56,7 @@ bench( pkg+'::throughput,baseline', function benchmark( b ) {
}
});

bench( pkg+'::throughput', function benchmark( b ) {
bench( format( '%s::throughput', pkg ), function benchmark( b ) {
var stream;
var opts;
var i;
Expand Down Expand Up @@ -84,7 +85,7 @@ bench( pkg+'::throughput', function benchmark( b ) {
}
});

bench( pkg+'::throughput,noop_callback', function benchmark( b ) {
bench( format( '%s::throughput,noop_callback', pkg ), function benchmark( b ) {
var stream;
var opts;
var i;
Expand Down Expand Up @@ -113,7 +114,7 @@ bench( pkg+'::throughput,noop_callback', function benchmark( b ) {
}
});

bench( pkg+'::throughput,object_mode', function benchmark( b ) {
bench( format( '%s::throughput,object_mode', pkg ), function benchmark( b ) {
var stream;
var opts;
var i;
Expand Down Expand Up @@ -143,7 +144,7 @@ bench( pkg+'::throughput,object_mode', function benchmark( b ) {
}
});

bench( pkg+'::throughput,object_mode,noop_callback', function benchmark( b ) {
bench( format( '%s::throughput,object_mode,noop_callback', pkg ), function benchmark( b ) {
var stream;
var opts;
var i;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,13 +25,14 @@ var bench = require( '@stdlib/bench' );
var inherit = require( '@stdlib/utils/inherit' );
var noop = require( '@stdlib/utils/noop' );
var nextTick = require( '@stdlib/utils/next-tick' );
var format = require( '@stdlib/string/format' );
var pkg = require( './../package.json' ).name;
var debugStream = require( './../lib' );


// MAIN //

bench( pkg+'::throughput,baseline', function benchmark( b ) {
bench( format( '%s::throughput,baseline', pkg ), function benchmark( b ) {
var i;

i = 0;
Expand All @@ -57,7 +58,7 @@ bench( pkg+'::throughput,baseline', function benchmark( b ) {
}
});

bench( pkg+'::throughput', function benchmark( b ) {
bench( format( '%s::throughput', pkg ), function benchmark( b ) {
var stream;
var opts;
var i;
Expand Down Expand Up @@ -99,7 +100,7 @@ bench( pkg+'::throughput', function benchmark( b ) {
}
});

bench( pkg+'::throughput,noop_callback', function benchmark( b ) {
bench( format( '%s::throughput,noop_callback', pkg ), function benchmark( b ) {
var stream;
var opts;
var i;
Expand Down Expand Up @@ -141,7 +142,7 @@ bench( pkg+'::throughput,noop_callback', function benchmark( b ) {
}
});

bench( pkg+'::throughput,object_mode', function benchmark( b ) {
bench( format( '%s::throughput,object_mode', pkg ), function benchmark( b ) {
var stream;
var opts;
var i;
Expand Down Expand Up @@ -184,7 +185,7 @@ bench( pkg+'::throughput,object_mode', function benchmark( b ) {
}
});

bench( pkg+'::throughput,object_mode,noop_callback', function benchmark( b ) {
bench( format( '%s::throughput,object_mode,noop_callback', pkg ), function benchmark( b ) {
var stream;
var opts;
var i;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@

var Readable = require( 'readable-stream' ).Readable;
var bench = require( '@stdlib/bench' );
var format = require( '@stdlib/string/format' );
var pkg = require( './../package.json' ).name;
var emptyStream = require( './../lib' );

Expand All @@ -47,7 +48,7 @@ bench( pkg, function benchmark( b ) {
b.end();
});

bench( pkg+':objectMode', function benchmark( b ) {
bench( format( '%s:objectMode', pkg ), function benchmark( b ) {
var s;
var i;

Expand All @@ -66,7 +67,7 @@ bench( pkg+':objectMode', function benchmark( b ) {
b.end();
});

bench( pkg+'::factory', function benchmark( b ) {
bench( format( '%s::factory', pkg ), function benchmark( b ) {
var createStream;
var s;
var i;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@

var Readable = require( 'readable-stream' ).Readable;
var bench = require( '@stdlib/bench' );
var format = require( '@stdlib/string/format' );
var pkg = require( './../package.json' ).name;
var arrayStream = require( './../lib' );

Expand Down Expand Up @@ -50,7 +51,7 @@ bench( pkg, function benchmark( b ) {
b.end();
});

bench( pkg+':objectMode', function benchmark( b ) {
bench( format( '%s:objectMode', pkg ), function benchmark( b ) {
var arr;
var s;
var i;
Expand All @@ -72,7 +73,7 @@ bench( pkg+':objectMode', function benchmark( b ) {
b.end();
});

bench( pkg+'::factory', function benchmark( b ) {
bench( format( '%s::factory', pkg ), function benchmark( b ) {
var createStream;
var arr;
var s;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,13 +24,14 @@ var WritableStream = require( 'readable-stream' ).Writable; // eslint-disable-li
var bench = require( '@stdlib/bench' );
var inherit = require( '@stdlib/utils/inherit' );
var nextTick = require( '@stdlib/utils/next-tick' );
var format = require( '@stdlib/string/format' );
var pkg = require( './../package.json' ).name;
var arrayStream = require( './../lib' );


// MAIN //

bench( pkg+'::throughput,baseline', function benchmark( b ) {
bench( format( '%s::throughput,baseline', pkg ), function benchmark( b ) {
var i;

i = 0;
Expand All @@ -56,7 +57,7 @@ bench( pkg+'::throughput,baseline', function benchmark( b ) {
}
});

bench( pkg+'::throughput:highWaterMark=<default>', function benchmark( b ) {
bench( format( '%s::throughput:highWaterMark=<default>', pkg ), function benchmark( b ) {
var rStream;
var wStream;
var opts;
Expand Down Expand Up @@ -107,7 +108,7 @@ bench( pkg+'::throughput:highWaterMark=<default>', function benchmark( b ) {
}
});

bench( pkg+'::throughput:highWaterMark=0', function benchmark( b ) {
bench( format( '%s::throughput:highWaterMark=0', pkg ), function benchmark( b ) {
var rStream;
var wStream;
var opts;
Expand Down Expand Up @@ -160,7 +161,7 @@ bench( pkg+'::throughput:highWaterMark=0', function benchmark( b ) {
}
});

bench( pkg+'::throughput,object_mode:highWaterMark=<default>', function benchmark( b ) {
bench( format( '%s::throughput,object_mode:highWaterMark=<default>', pkg ), function benchmark( b ) {
var rStream;
var wStream;
var opts;
Expand Down Expand Up @@ -213,7 +214,7 @@ bench( pkg+'::throughput,object_mode:highWaterMark=<default>', function benchmar
}
});

bench( pkg+'::throughput,object_mode:highWaterMark=0', function benchmark( b ) {
bench( format( '%s::throughput,object_mode:highWaterMark=0', pkg ), function benchmark( b ) {
var rStream;
var wStream;
var opts;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@

var Readable = require( 'readable-stream' ).Readable;
var bench = require( '@stdlib/bench' );
var format = require( '@stdlib/string/format' );
var pkg = require( './../package.json' ).name;
var circularArrayStream = require( './../lib' );

Expand Down Expand Up @@ -50,7 +51,7 @@ bench( pkg, function benchmark( b ) {
b.end();
});

bench( pkg+':objectMode', function benchmark( b ) {
bench( format( '%s:objectMode', pkg ), function benchmark( b ) {
var arr;
var s;
var i;
Expand All @@ -72,7 +73,7 @@ bench( pkg+':objectMode', function benchmark( b ) {
b.end();
});

bench( pkg+'::factory', function benchmark( b ) {
bench( format( '%s::factory', pkg ), function benchmark( b ) {
var createStream;
var arr;
var s;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,13 +24,14 @@ var WritableStream = require( 'readable-stream' ).Writable; // eslint-disable-li
var bench = require( '@stdlib/bench' );
var inherit = require( '@stdlib/utils/inherit' );
var nextTick = require( '@stdlib/utils/next-tick' );
var format = require( '@stdlib/string/format' );
var pkg = require( './../package.json' ).name;
var circularArrayStream = require( './../lib' );


// MAIN //

bench( pkg+'::throughput,baseline', function benchmark( b ) {
bench( format( '%s::throughput,baseline', pkg ), function benchmark( b ) {
var i;

i = 0;
Expand All @@ -56,7 +57,7 @@ bench( pkg+'::throughput,baseline', function benchmark( b ) {
}
});

bench( pkg+'::throughput:highWaterMark=<default>', function benchmark( b ) {
bench( format( '%s::throughput:highWaterMark=<default>', pkg ), function benchmark( b ) {
var rStream;
var wStream;
var opts;
Expand Down Expand Up @@ -104,7 +105,7 @@ bench( pkg+'::throughput:highWaterMark=<default>', function benchmark( b ) {
}
});

bench( pkg+'::throughput:highWaterMark=0', function benchmark( b ) {
bench( format( '%s::throughput:highWaterMark=0', pkg ), function benchmark( b ) {
var rStream;
var wStream;
var opts;
Expand Down Expand Up @@ -154,7 +155,7 @@ bench( pkg+'::throughput:highWaterMark=0', function benchmark( b ) {
}
});

bench( pkg+'::throughput,object_mode:highWaterMark=<default>', function benchmark( b ) {
bench( format( '%s::throughput,object_mode:highWaterMark=<default>', pkg ), function benchmark( b ) {
var rStream;
var wStream;
var opts;
Expand Down Expand Up @@ -204,7 +205,7 @@ bench( pkg+'::throughput,object_mode:highWaterMark=<default>', function benchmar
}
});

bench( pkg+'::throughput,object_mode:highWaterMark=0', function benchmark( b ) {
bench( format( '%s::throughput,object_mode:highWaterMark=0', pkg ), function benchmark( b ) {
var rStream;
var wStream;
var opts;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@

var Readable = require( 'readable-stream' ).Readable;
var bench = require( '@stdlib/bench' );
var format = require( '@stdlib/string/format' );
var pkg = require( './../package.json' ).name;
var constantStream = require( './../lib' );

Expand All @@ -47,7 +48,7 @@ bench( pkg, function benchmark( b ) {
b.end();
});

bench( pkg+':objectMode', function benchmark( b ) {
bench( format( '%s:objectMode', pkg ), function benchmark( b ) {
var s;
var i;

Expand All @@ -66,7 +67,7 @@ bench( pkg+':objectMode', function benchmark( b ) {
b.end();
});

bench( pkg+'::factory', function benchmark( b ) {
bench( format( '%s::factory', pkg ), function benchmark( b ) {
var createStream;
var s;
var i;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,13 +24,14 @@ var WritableStream = require( 'readable-stream' ).Writable; // eslint-disable-li
var bench = require( '@stdlib/bench' );
var inherit = require( '@stdlib/utils/inherit' );
var nextTick = require( '@stdlib/utils/next-tick' );
var format = require( '@stdlib/string/format' );
var pkg = require( './../package.json' ).name;
var constantStream = require( './../lib' );


// MAIN //

bench( pkg+'::throughput,baseline', function benchmark( b ) {
bench( format( '%s::throughput,baseline', pkg ), function benchmark( b ) {
var i;

i = 0;
Expand All @@ -56,7 +57,7 @@ bench( pkg+'::throughput,baseline', function benchmark( b ) {
}
});

bench( pkg+'::throughput:highWaterMark=<default>', function benchmark( b ) {
bench( format( '%s::throughput:highWaterMark=<default>', pkg ), function benchmark( b ) {
var rStream;
var wStream;
var opts;
Expand Down Expand Up @@ -101,7 +102,7 @@ bench( pkg+'::throughput:highWaterMark=<default>', function benchmark( b ) {
}
});

bench( pkg+'::throughput:highWaterMark=0', function benchmark( b ) {
bench( format( '%s::throughput:highWaterMark=0', pkg ), function benchmark( b ) {
var rStream;
var wStream;
var opts;
Expand Down Expand Up @@ -148,7 +149,7 @@ bench( pkg+'::throughput:highWaterMark=0', function benchmark( b ) {
}
});

bench( pkg+'::throughput,object_mode:highWaterMark=<default>', function benchmark( b ) {
bench( format( '%s::throughput,object_mode:highWaterMark=<default>', pkg ), function benchmark( b ) {
var rStream;
var wStream;
var opts;
Expand Down Expand Up @@ -195,7 +196,7 @@ bench( pkg+'::throughput,object_mode:highWaterMark=<default>', function benchmar
}
});

bench( pkg+'::throughput,object_mode:highWaterMark=0', function benchmark( b ) {
bench( format( '%s::throughput,object_mode:highWaterMark=0', pkg ), function benchmark( b ) {
var rStream;
var wStream;
var opts;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@
var Readable = require( 'readable-stream' ).Readable;
var randu = require( '@stdlib/random/iter/randu' );
var bench = require( '@stdlib/bench' );
var format = require( '@stdlib/string/format' );
var pkg = require( './../package.json' ).name;
var iteratorStream = require( './../lib' );

Expand Down Expand Up @@ -51,7 +52,7 @@ bench( pkg, function benchmark( b ) {
b.end();
});

bench( pkg+':objectMode', function benchmark( b ) {
bench( format( '%s:objectMode', pkg ), function benchmark( b ) {
var it;
var s;
var i;
Expand All @@ -73,7 +74,7 @@ bench( pkg+':objectMode', function benchmark( b ) {
b.end();
});

bench( pkg+'::factory', function benchmark( b ) {
bench( format( '%s::factory', pkg ), function benchmark( b ) {
var createStream;
var it;
var s;
Expand Down
Loading