gistfile1.txt

// bad i think?
function currentUserStream () {
    return Rx.Observable.create((o) => {
        const fn = () => {
            o.next(Math.random());
        };
        setInterval(fn, 250);
    }).take(11).share();
}

module.exports = {
    currentUserStream: currentUserStream(),
};

//good i think?

function currentUserStream () {
    return Rx.Observable.create((o) => {
        const fn = () => {
            o.next(Math.random());
        };
        setInterval(fn, 500);
    }).take(11);
}

module.exports = {
    currentUserStream,
};