Reactive Programming snippets

__rx__.md

RxJS personal examples

Two consequent dependent API calls

const { XMLHttpRequest } = require('xmlhttprequest');
const { ajax } = require('rxjs/ajax');
const { mergeMap } = require('rxjs/operators/mergeMap');

const config = {
  crossDomain: true,
  createXHR: function () {
    return new XMLHttpRequest();
  }
};

ajax({ url: 'http://localhost:5050/posts/1', ...config })
  .pipe(
    mergeMap((res1) =>
      ajax({ url: 'http://localhost:5050/posts/2', body: res1.response, method: 'put', ...config })
        .pipe(mergeMap(res2 => [res2]))
    )
  ).subscribe();