​

​

function calculateWithStreams(base) {

​

            let now2 = new Date();

            Rx.Observable.fromArray(base).map((i) => i * i).filter((i) => i < 500).map((i) => i + i).reduce((acc, x) => {

                    return acc + x;

                }, 0)

                .subscribe((x) => {

                        console.log ("Streams sum is " + x);

                    },

                    (err) => {

                        console.log("Error: " + err);

                    },

                    () => {

                        let current2 = new Date();

                        console.log("Streams took " + (current2.getTime() - now2.getTime()));

                        console.log("Streams at " + now2 + " and finished at " + current2);

​

                    });

        } 

​

function calculateWithArrays(base) {

            let now = new Date();

            let sum = base.map((i) => i * i).filter((i) => i < 500).map((i) => i + i).reduce((x, y) => x + y);

            let current = new Date();

            console.log("Sum with arrays is " + sum);

            console.log("Arrays took " + (current.getTime() - now.getTime()));

            console.log("Arrays at " + now + " and finished at " + current);

        }

​

function calculate() {

​

             const n = 10000;

            // generate random array

            let base = [n];

            for (let i = 0; i < n; i++) {

                base[i] = i;

            }

            calculateWithStreams(base);

            calculateWithArrays(base);

        }      

​

calculate();