Observables 1

Learning Observables

by Suman Kumar

HTML

<div class="container">

</div>
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/2.2.26/rx.js"></script>
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/2.2.26/rx.async.js"></script>
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/2.2.26/rx.coincidence.js"></script>
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/2.2.26/rx.binding.js"></script>
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/2.2.26/rx.time.js"></script>
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs-dom/2.0.7/rx.dom.js"></script>

JavaScript

var observable = Rx.Observable.create(function (observer) {
  observer.next(1);
  observer.next(2);
  
  setTimeout(() => {
  	observer.next(3);
  }, 4000);
});


observable.subscribe(
  value => console.log('Observer one : '+value),
  err => {},
  () => console.log('End of Observer one')
);


setTimeout(() => {
	observable.subscribe(
  value => console.log('Observer two : '+value),
  err => {},
  () => console.log('End of Observer two')
	);
}, 2000);


/**setTimeout(() => {
	observable.subscribe(
  value => console.log('Observer three : '+value),
  err => {},
  () => console.log('End of Observer three')
	);
}, 6000);*/