Паттерн Observer

Принципы

• Observable (Subject) оповещает подписчиков о новых данных методом next.
• Каждый подписчик (subscribe) получает одинаковые уведомления и может отписаться (unsubscribe).
• RxJS предоставляет готовую реализацию паттерна, удобную для реактивных сценариев.

Пример

import { Subject } from 'rxjs';

const news = new Subject<string>();

const tv1 = news.subscribe((v) => console.log(v + 'via Den TV'));
const tv2 = news.subscribe((v) => console.log(v + 'via Batcave TV'));

news.next('Breaking news: ');
news.next('The war is over ');

tv1.unsubscribe();

Практика

• Храните ссылки на подписки, чтобы гарантированно освобождать ресурсы (subscription.unsubscribe()).
• Используйте пайпы (news.pipe(...)) для трансформации данных перед доставкой.
• При создании собственных Observable следите за управлением завершением (complete) и ошибками (error).