Create an observable

obs.js

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}`);
});
/**
 * Print:
 * Output Obs 1 : Hello
 * Output Obs 1 : Reactive
 * Output Obs 1 : World
 * /