Bring back the forkJoin

gistfile1.txt

    Rx.Observable.forkJoin = function (sources) {

        var tempSources = arguments.length > 1 ? arguments : sources;

        return Rx.Observable
                 .fromArray(tempSources)
                 .selectMany(function (o, i) {
                     return o.takeLast(1).select(function (value) { return { i: i, value: value }; });
                 })
                 .aggregate({ array: [], count: 0 }, function (results, result) {
                     results.array[result.i] = result.value;
                     return {
                         array: results.array,
                         count: results.count + 1
                     };
                 })
                 .where(function (results) { return results.count === tempSources.length; })
                 .select(function (results) { return results.array; });
    };