JSFiddle - React, Tailwind, and code Playground

by Amit Vishwakarma

HTML

<script src="https://unpkg.com/@reactivex/[email protected]/dist/global/Rx.js"></script>

<button>Click me</button>

JavaScript

var button = document.querySelector('button');


var observer = {
  next: function(value) {
    console.log(value);
  },
  error: function(error) {
    console.log(error);
  },
  complete: function() {
    console.log("complete")
  }

}

//Rx.Observable.fromEvent(button,'click')
//.subscribe((value) => console.log(value.clientX));

//Rx.Observable.fromEvent(button,'click')
//.subscribe(observer);

var subscription = Rx.Observable.create(function(obs) {
  /* obs.next('A Value');

  setTimeout(function(){

  obs.complete('complete');
  },2000);

  obs.next('A Second Value'); */

  button.onclick = function() {
    obs.next(event);
  }

}).subscribe(observer);


setTimeout(function() {
  subscription.unsubscribe();
}, 5000);