RxJS Subject

by ardydedase

HTML

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.6.7/rxjs.umd.min.js"></script>

JavaScript

const subject$ = new rxjs.Subject();

subject$.subscribe(x => console.log('Subscriber A: ' + x));
subject$.next(1);
subject$.next(2);


// silently prevent new subscriptions
//subject$.complete(); 

// throw an error if there is a new subscription
//subject$.unsubscribe(); 


subject$.subscribe(x => console.log('Subscriber B: ' + x));
subject$.next(3);