var CountStream = require('more-streams').CountStream;

var CountStream = require('more-streams/CountStream');

var ConsoleStream = require('more-streams/ConsoleStream');
var out = new ConsoleStream({
  colors: [{
    match: /error/g,
    styles: ['red', 'bold']
  }]
});
otherStream.pipe(out);
 
// -> prints to console with errors in bold and red

var CountStream = require('more-streams/CountStream');
var counter = new CountStream();
counter.on('end', () => console.log(counter.count)); // -> prints total stream bytes count
otherStream.pipe(counter).pipe(process.stdout);

var CountStream = require('more-streams/CountStream');
var counter = new CountStream();
counter.addMarker(10);
counter.on('marker', (count, counter) => console.log(count, counter.count)); // -> prints 10, 10
otherStream.pipe(counter).pipe(process.stdout);

var MultiplexStream = require('more-streams/MultiplexStream');
var mux = new MultiplexStream();
otherStream.pipe(mux).pipe([process.stdout, process.stdout]);
 
// -> prints same output to 2 consoles

var OffsetStream = require('more-streams/OffsetStream');
var offset = new OffsetStream({start: 10, end: 20});
otherStream.pipe(offset).pipe(process.stdout);
 
// -> prints from 10th byte to 20th byte of the total stream

var SequenceStream = require('more-streams/SequenceStream');
var demux = new SequenceStream();
demux.chain(otherStream1, otherStream2, otherStream3);
demux.pipe(process.stdout);
 
// -> prints in order from stream 1,2 and then 3 to console.

var Sink = require('more-streams/Sink');
var buffer = new Sink({ buffer: true });
buffer.on('end', () => console.log(buffer.message('hex')));  // -> prints to console
otherStream.pipe(buffer);

var Writer = require('more-streams/Writer');
var output = new Writer();
output.write('message');
output.pipe(process.stdout);
 
// -> prints to console 'message'