stream-balance

This library contains balance1 and balance2.

``js

var fromArray = require("stream-from-array");
var through = require("through2");

var balanceSync = require("./").balance1;
var balanceAsync = require("./").balance2;

var stream1 = function(chunk, _, cb) {
setTimeout(function() {
console.log("stream1:" + chunk);
cb(null, chunk);
}, 5000);
}

var stream2 = function(chunk, _, cb) {
setTimeout(function() {
console.log("stream2:" + chunk);
cb(null, chunk);
}, 3000);
}

var stream3 = function(chunk, _, cb) {
setTimeout(function() {
console.log("stream3:" + chunk);
cb(null, chunk);
}, 8000);
}

var stream4 = function(chunk, _, cb) {
setTimeout(function() {
console.log("stream4:" + chunk);
cb(null, chunk);
}, 7000);
}

var handle = through(stream1);
var handle1 = through(stream2);
var handle2 = through(stream3);
var handle3 = through(stream4);

num = ["1", "2", "3", "4", "5", "6", "7", "8", "9"];

fromArray(num).pipe(balanceSync([handle, handle1, handle2, handle3])).pipe(process.stdout);
fromArray(num).pipe(balanceAsync([handle, handle1, handle2, handle3])).pipe(process.stdout);

``