Реактивное программирование приобрело значительную популярность в последние годы благодаря способности эффективно обрабатывать асинхронные события и потоки данных. Одной из фундаментальных концепций реактивного программирования являются наблюдаемые. Наблюдаемые — это последовательности событий или значений, которые можно наблюдать и на которые можно реагировать. В этой статье мы рассмотрим ключевые различия между холодными и горячими наблюдаемыми, а также приведем примеры кода, иллюстрирующие каждую концепцию.

Холодные наблюдения:

Холодные наблюдаемые — наиболее распространенный тип наблюдаемых в реактивном программировании. Каждый подписчик на холодную наблюдаемую получает свою независимую последовательность событий. Другими словами, наблюдаемый объект начинает отправлять события только тогда, когда на него подписывается подписчик. Это означает, что каждый подписчик получает полную последовательность событий с самого начала.

Вот пример создания холодного наблюдаемого с использованием RxJS в JavaScript:

const { Observable } = require('rxjs');
const coldObservable = new Observable((subscriber) => {
  subscriber.next('Event 1');
  subscriber.next('Event 2');
  subscriber.next('Event 3');
});
coldObservable.subscribe((event) => {
  console.log('Subscriber 1:', event);
});
coldObservable.subscribe((event) => {
  console.log('Subscriber 2:', event);
});

Выход:

Subscriber 1: Event 1
Subscriber 1: Event 2
Subscriber 1: Event 3
Subscriber 2: Event 1
Subscriber 2: Event 2
Subscriber 2: Event 3

В приведенном выше примере и подписчик 1, и подписчик 2 получают полную последовательность событий независимо друг от друга.

Горячие наблюдения:

Горячие наблюдаемые, с другой стороны, — это наблюдаемые, которые генерируют события независимо от того, есть ли подписчики или нет. Подписчики горячего наблюдаемого присоединяются к последовательности событий в момент подписки, потенциально пропуская некоторые более ранние события. Горячие наблюдения полезны, если вы хотите поделиться потоком событий между несколькими подписчиками.

Давайте посмотрим на яркий пример с использованием RxJS:

const { Subject } = require('rxjs');
const hotObservable = new Subject();
hotObservable.next('Event 1');
hotObservable.next('Event 2');
hotObservable.next('Event 3');
hotObservable.subscribe((event) => {
  console.log('Subscriber 1:', event);
});
hotObservable.subscribe((event) => {
  console.log('Subscriber 2:', event);
});

Выход:

Subscriber 1: Event 1
Subscriber 1: Event 2
Subscriber 1: Event 3
Subscriber 2: Event 1
Subscriber 2: Event 2
Subscriber 2: Event 3

В этом примере и подписчик 1, и подписчик 2 присоединяются к горячему наблюдаемому в момент подписки, получая события, созданные после их подписки.

Понимание разницы между холодными и горячими наблюдаемыми имеет решающее значение в реактивном программировании. Холодные наблюдаемые предоставляют каждому подписчику независимую последовательность событий, тогда как горячие наблюдаемые разделяют одну и ту же последовательность событий среди всех подписчиков. Выбрав подходящий тип наблюдаемой, вы сможете спроектировать эффективные и масштабируемые реактивные системы.

Помните, что при использовании холодных наблюдаемых каждый подписчик получает полную последовательность событий с самого начала, тогда как горячие наблюдаемые отправляют события независимо от подписчиков, потенциально пропуская некоторые более ранние события. Используйте холодные наблюдаемые, если вам нужна полная последовательность, и горячие наблюдаемые, если вы хотите поделиться потоком событий между подписчиками.

Удачного вам реактивного программирования!