В RxJS наблюдаемые используются для представления потоков данных. Горячая и холодная категоризация наблюдаемых относится к тому, когда они начинают излучать значения.
Горячая/холодная категоризация наблюдаемых важна, поскольку она определяет поведение наблюдаемых и влияет на то, как подписчики получают значения. Например, если несколько подписчиков прослушивают горячий наблюдаемый объект, они могут получать значения в другом порядке или в разное время, в зависимости от того, когда они подписываются. С другой стороны, если несколько подписчиков прослушивают холодный наблюдаемый объект, они получат одни и те же значения в одном и том же порядке.
Горячий наблюдаемый объект — это тот, который начинает выдавать значения независимо от того, есть ли подписчики, которые прослушивают эти значения. Примеры горячих наблюдаемых включают щелчки мышью, движения мыши или события таймера. Как только горячая наблюдаемая начнет выдавать значения, все новые подписчики получат эти значения, но они не получат значения, которые были выданы до их подписки.
Примером горячего наблюдаемого в RxJS является событие щелчка мыши. Событие щелчка мыши может генерироваться непрерывно и будет выдавать значения (координаты щелчка), даже если нет подписчиков, которые могли бы прослушивать события. Например:
const { fromEvent } = rxjs;
const documentclickHandler = fromEvent(document, 'click');
documentclickHandler.subscribe(event => console.log(event.clientX, event.clientY));
В этом примере функция fromEvent создает горячую наблюдаемую, которая выдает значения для событий щелчка мыши в документе. Всякий раз, когда происходит событие щелчка мыши, свойства события clientX и clientY записываются в консоль. Этот пример демонстрирует поведение горячих наблюдаемых объектов, где события генерируются непрерывно, даже если нет подписчиков, которые могли бы прослушивать события.
Холодный наблюдаемый объект, с другой стороны, не начинает выдавать значения, пока не появится хотя бы один подписчик. Каждый подписчик получит полную последовательность значений с начала последовательности. Хорошим примером холодного наблюдения является HTTP-запрос. Запрос не выполняется до тех пор, пока подписчик не подпишется, и каждый подписчик получит один и тот же ответ.
Примером холодного наблюдения в RxJS является HTTP-запрос. HTTP-запрос выполняется только тогда, когда есть подписчик для получения ответа. Например:
const { from } = rxjs;
const { ajax } = rxjs.ajax;
const coldObservable = from(ajax.getJSON('https://api.example.com/data'));
coldObservable.subscribe(data => console.log(data));
В этом примере функция from создает холодную наблюдаемую, которая представляет HTTP-запрос GET к https://api.example.com/data. Функция ajax.getJSON используется для выполнения запроса, а ответ возвращается в виде объекта JSON. Когда подписчик подписывается на холодное наблюдаемое, выполняется HTTP-запрос, и данные JSON записываются в консоль.
Этот пример демонстрирует поведение холодных наблюдаемых, когда базовый источник данных (запрос HTTP) выполняется только при наличии подписчика для получения ответа. Если несколько подписчиков подписываются на один и тот же холодный наблюдаемый объект, каждый подписчик получит один и тот же ответ.
Таким образом, горячие наблюдаемые часто используются для непрерывных потоков данных в реальном времени, в то время как холодные наблюдаемые используются для данных, которые производятся по запросу.
