Academind - 2

by Suman Kumar

HTML

<div class="container">
 
</div>


<script src="https://cdnjs.cloudflare.com/ajax/libs/jquery/3.2.1/jquery.min.js"></script>
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.4.2/Rx.min.js"></script>

JavaScript

var observer = {
	next : function(val){
  	console.log(val);
  },
  error : function(err){
  	console.log(err);
  },
}

Rx.Observable.create((obs) => {
	obs.next('One');
  obs.next('Two');
  obs.error('Erroooor');
  obs.next('One');
})
.subscribe(observer);