JSFiddle - React, Tailwind, and code Playground

by gianlucaguarini

HTML

<script src="https://rawgit.com/Reactive-Extensions/RxJS/master/dist/rx.min.js"></script>

JavaScript

var i = 0,
    streams = [],
    noop = function () {},
    onValue = function (value) {
        var div = document.createElement('div');
        div.innerHTML = value.whathever;
        document.body.appendChild(div);
    },
    ITEMS_COUNT = 5000;

while (i++ < ITEMS_COUNT) {
    console.log(Rx.Observable);
    var source = Rx.Observable.create(function(observer){
            streams.push(observer);
        }),
        j = 3;
    
    source.subscribe(onValue);
    while (j--) {
        source.subscribe(noop);
    }
    
}

while (--i) {
    streams[i - 1].onNext({
        whathever: i
    });
}