var streamLib = require('stream-lib');
 
// your streamlib module like:
// new streamLib.Random.Alphanumeric();

var streamLib = require('stream-lib');
 
// You need some source and destination streams
var fs = require('fs');
 
var sourceStream = fs.createReadStream('/path/to/your/source.file');
var destinationStream = fs.createWriteStream('/path/to/your/destination.file');
 
// You need the buffer stream
var objectMode = false;                    // This is optional
var bufferStream = new streamLib.Buffer({objectMode: objectMode});
 
sourceStream.pipe(decoderStream)
    .pipe(destinationStream);
 

var streamLib = require('stream-lib');
 
// You need some source and destination streams
var fs = require('fs');
 
var firstStream = fs.createReadStream('/path/to/your/first.file');
var secondStream = fs.createReadStream('/path/to/your/second.file');
var thirdStream = fs.createReadStream('/path/to/your/third.file');
var destinationStream = fs.createWriteStream('/path/to/your/destination.file');
 
// You need the concat stream
var concatStream = new streamLib.Concat();
 
firstStream
    .pipe(concatStream);
secondStream
    .pipe(concatStream);
thirdStream
    .pipe(concatStream);
 
concatStream.pipe(destinationStream);
 

var streamLib = require('stream-lib');
 
// You need some source and destination streams
var fs = require('fs');
 
var sourceStream = fs.createReadStream('/path/to/your/source.file');
var destinationStream = fs.createWriteStream('/path/to/your/destination.file');
 
// You need the buffer stream
var delay = 500;                                  // Delay in milli-seconds (Zero makes it just asynchronous)
var objectMode = false;                           // This is optional
var delayStream = new streamLib.Pipe.Delay({objectMode: objectMode});
 
sourceStream.pipe(delayStream)
    .pipe(destinationStream);
 

var streamLib = require('stream-lib');
 
// Create an event stream
 
var eventStream = new streamLib.Event();
 
 
// For sending and getting Events
eventStream.receive('test', function (data) {
    console.log('Test received:', data);
});
 
eventStream.send('test', 'Hello!');
 
 
var EventEmitter = require('events').EventEmitter;
 
// anotherEventStream
 
var anotherEventStream = new streamLib.Event();
 
anotherEventStream.receive('test', function () {});
 
eventStr.pipe(anotherEventStream);
 

var streamLib = require('stream-lib');
 
// Create an unit
 
var unit = new streamLib.Unit();
 
// Create streams for the unit
 
var hexDecoder = new streamLib.HexEncoder();
var toUpperCaseStream = new streamLib.UpperCase();
 
// Combine to an unit
 
HexEncoder
    .pipe(toUpperCaseStream);
 
unit.setWritableStream(HexEncoder);
unit.setReadableStream(toUpperCaseStream);
 
// Now the unit create an upper case hex string
 

var streamLib = require('stream-lib');
 
// Create an sequence
 
var sequence = new streamLib.Sequence();
 
sequence.write('1');
sequence.write('2');
sequence.write('4');
sequence.write('8');
sequence.write('16');
sequence.end();
 
sequence.on('data', function (chunk) {
    console.log(chunk.toString());
});
 
// Outputs 1 2 4 8 16 1 2 4 8 16 1 2 4 8 16 1 2 4 8 16 1 2 4 8 16 1 2 4 8 16 1 2 4 8 16 1 2 4 8 16 ...
 

var streamLib = require('stream-lib');
 
// Create a measure
 
var measure = new streamLib.Measure.Capacity();
 
// Create some asynchronous pipes
 
var firstPipe = new streamLib.Pipe.Async();
var secondPipe = new streamLib.Pipe.Async();
var thirdPipe = new streamLib.Pipe.Async();
 
measure.measureInlet
    .pipe(firstPipe)
    .pipe(secondPipe)
    .pipe(thirdPipe)
    .pipe(measure.measureOutlet);
 
measure.measureInlet.write('1');
measure.measureInlet.write('2');
measure.measureInlet.write('3');
measure.measureInlet.write('4');
measure.measureInlet.write('5');
measure.measureInlet.end();
 
measure.on('data', function (chunk) {
    console.log(chunk.capacity);       // Now you got the measured capacity of the streams
});