Observable - Cold

by Krishna Ananthi

HTML

<script src="http://cdnjs.cloudflare.com/ajax/libs/rxjs/2.2.26/rx.js"></script>

JavaScript 1.7

let observer = new  Rx.Observable((o) => {
  setTimeout(() => {
    o.next(1);
  }, 1000);
  setTimeout(() => {
    o.next(2);
  }, 2000);
  setTimeout(() => {
    o.next(3);
  }, 3000); 
});
 setTimeout(() => {
    observer.subscribe(v=>{console.log(v); });
  }, 0); 
 setTimeout(() => {
    observer.subscribe(v=>{console.log('fff',v); });
  }, 2000);