promise-iterator-fork.js

PromiseIterator.prototype.fork = function (length) {
    var buffers = new Array(length).map(function () {
        return new Buffer();
    });
    var inputs = buffers.map(function (buffer) {
        return buffer.in;
    });
    var outputs = buffers.map(function (buffer) {
        return buffer.out;
    });
    this.forEach(function (value, index) {
        return Promise.all(inputs.map(function (input) {
            return input.yield(value, index);
        }));
    }).then(function (value) {
        return Promise.all(inputs.map(function (input) {
            return input.return(value);
        }));
    }, function (error) {
        return Promise.all(inputs.map(function (input) {
            return input.throw(value);
        }));
    }).done();
    return outputs;
};