http-rx-dom-multiple.js

// with rx-dom@7.0.3 & rxjs@5.5.6
import { combineLatest } from 'rxjs/observable/combineLatest';
import { ajax } from 'rxjs/observable/dom/ajax';
import { tap, map } from 'rxjs/operators';

const BASE_URL = 'http://myurl.com';

// Retour un observable AJAX formé par un argument
function loginUserAccordingToData({ someDataThis }) {
  return ajax.post(`${BASE_URL}/data`, { someDataThis })
    .pipe(
      map((response) => {
        const { data } = response;
        // do something....
        return data;
      })
    );
}

// Retour aussi un observable AJAX formé par un argument
function getUserProfileAccordingToData({ someDataThat }) {
  return ajax.getJSON(`${BASE_URL}/profile?data=${someDataThat}}`);
}

// On va succéder et combiner les observables et donc les requêtes
const myBigRequest = ajax.getJSON(`${BASE_URL}/data`)
  .pipe(
     switchMap(
      (data) => combineLatest(loginUserAccordingToData(data), getUserProfileAccordingToData())
     )
  );

// On exécute le tout
myBigRequest.subscribe(
  ([loginData, profileData]) => {
    alert('SUCCESS !!');
    console.log(loginData, profileData);
  },
  (err) => {
    alert('ERROR !!');
    console.error(err)
  }
);