Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import { Subject } from 'rxjs';
- class AwesomeMessageBus {
- private messagesSubject = new Subject<string>();
- readonly messages$ = this.messagesSubject.asObservable();
- sendMessage(message: string) {
- console.log(`Next awesome message: ${message}`);
- this.messagesSubject.next(message);
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement