RxJS - AsyncSubject

RxJS - AsyncSubject

by ayyanarj

HTML

<script src="https://unpkg.com/@reactivex/[email protected]/dist/global/Rx.js"></script>

<input type="button" id="button1" value="Click Me" />


<p>
Value: 
<span></span>
</p>

JavaScript

var sub = new Rx.AsyncSubject();

sub.subscribe(value =>  console.log(`Subscriber A => `, value));

sub.next(1);
sub.next(2);
sub.next(3);
sub.next(4);

sub.subscribe(value => console.log(`Subscriber B => `, value));

sub.complete();