Christopher2K

// Initialisation de la requête XHR
const request = new window.XMLHttpRequest();

// Options de la requête
const options = {
  method: 'GET',
  url: 'http://myurl.com',
  async: true
};

Christopher2K

function myDataStream(observer) {
  observer.next('Hello');
  observer.next('Reactive');
  observer.next('World');
}

const obsOne = Rx.Observable.create(myDataStream);
const subscriptionOne = obsOne.subscribe((data) => {
  console.log(`Output Obs 1 : ${data}`);
});