RxJS Subject

by Suman Kumar

HTML

<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 subjectOne = new Rx.Subject();

subjectOne.subscribe(v => console.log('consumer A: ' + v));
subjectOne.subscribe(v => console.log('consumer B: ' + v));

subjectOne.next();
subjectOne.next();