rxjs_1

by Ibrahim Islam

HTML

<script src="https://unpkg.com/@reactivex/rxjs@5.0.0-rc.1/dist/global/Rx.js"></script>

Babel + JSX

var Observable = Rx.Observable;

function xhr$(url) {
    return Observable.create(function (observer) {
        $.ajax({
            url: url,
            success: function (response) {
                observer.next(response);
            },
            error: function (jqXHR, status, error) {
                observer.error(error);
            },
            complete: function () {
                observer.complete();
            }
        });
    });
}

var one$ = xhr$('https://randomuser.me/api');
var two$ = xhr$('https://randomuser.me/api');

Observable.forkJoin(one$, two$)
.subscribe(res => console.log(res));