from

RxJS 5 from

by Echyzen

HTML

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.2.1/rxjs.umd.js"></script>
<script src="https://rawgit.com/eu81273/jsfiddle-console/master/console.js"></script>

JavaScript

var interval$ = rxjs.interval(1000);
var result$ = interval$.pipe(
	rxjs.operators.mergeMap(x =>
  	x === 3 ?
    	rxjs.throw('Three are bad') :
    	rxjs.of('a', 'b', 'c')
	)
);

result$.subscribe(x => console.log(x), e => console.error(e))