RxJS RC.2

by martinsikora

HTML

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.0.0-beta.12/Rx.js"></script>
<script src="https://unpkg.com/@reactivex/[email protected]/dist/global/Rx.js"></script>

JavaScript

const Observable = Rx.Observable;

function findUser(_) {
    return Observable.of([{name: "foo", user_id: 42}, {name: "bar", user_id: 21}]);
}

function getLastLogin(id) {
    return Observable.of(new Date());
}

var source = findUser('term')
    .mergeAll()
    .mergeMap(user => getLastLogin(user.user_id)
        .map(last_login => {
            user.last_login = last_login;
            return user;
        })
    )
    .toArray();

source.subscribe(val => console.log(val));