В чем разница между ColdPublisher и HotPublisher?

Разница между Cold Publisher и Hot Publisher

В Reactive Programming (особенно в Combine или RxSwift) фундаментальное различие между Cold Publisher и Hot Publisher определяет, как издатель (Publisher) взаимодействует с подписчиками (Subscriber) и когда начинает излучать значения.

Холодные издатели (Cold Publisher)

Cold Publisher — это ленивый издатель, который начинает излучать элементы только после подписки. Каждый новый подписчик получает полную, независимую последовательность значений с самого начала.

Ключевые характеристики:

• Начинает работу при подписке — не выполняет работу до появления первого Subscriber
• Индивидуальная последовательность для каждого подписчика — если два подписчика подписываются, каждый получает все значения с начала
• Переиздает значения — каждый подписчик получает полный набор данных
• Аналогия: Запись на DVD — каждый зритель смотрит фильм с начала независимо от других

Пример в Combine (Swift):

import Combine

// Пример Cold Publisher — последовательность
let coldPublisher = [1, 2, 3, 4, 5].publisher

// Первый подписчик
let subscription1 = coldPublisher
    .sink { value in
        print("Подписчик 1: \(value)")
    }

// Второй подписчик (получает те же значения с начала)
let subscription2 = coldPublisher
    .sink { value in
        print("Подписчик 2: \(value)")
    }

// Оба подписчика получат: 1, 2, 3, 4, 5

Типичные примеры Cold Publisher:

• Издатели из массивов или последовательностей ([1,2,3].publisher)
• Сетевые запросы (URLSession.dataTaskPublisher)
• Издатели, созданные через Future, Just, Deferred
• Файловые операции или чтение из базы данных

Горячие издатели (Hot Publisher)

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

Ключевые характеристики:

• Начинает работу сразу — излучает значения при создании, даже без подписчиков
• Разделяет последовательность между подписчиками — все подписчики получают одни и те же "живые" значения
• Может терять значения — подписчик, подписавшийся позже, не получит ранее изданные значения
• Аналогия: Радиостанция — слушатели слышат только то, что транслируется в момент подключения

Пример в Combine (Swift):

import Combine

// Создаем горячий издатель с Subject
let hotPublisher = PassthroughSubject<Int, Never>()
var cancellables = Set<AnyCancellable>()

// Издаем значения ДО подписки
hotPublisher.send(1)
hotPublisher.send(2)

// Первый подписчик (не получит 1 и 2)
hotPublisher
    .sink { value in
        print("Подписчик 1: \(value)")
    }
    .store(in: &cancellables)

hotPublisher.send(3) // Оба подписчика получат 3

// Второй подписчик (не получит 1, 2, 3)
hotPublisher
    .sink { value in
        print("Подписчик 2: \(value)")
    }
    .store(in: &cancellables)

hotPublisher.send(4) // Оба подписчика получат 4

Типичные примеры Hot Publisher:

• PassthroughSubject, CurrentValueSubject
• Издатели событий UI (кнопки, жесты)
• Уведомления (NotificationCenter)
• Таймеры (Timer.publish)
• Состояния приложения или общие ресурсы

Сравнительная таблица

Преобразования между типами

Иногда требуется преобразовать один тип в другой:

// Cold -> Hot: используем share()
let coldPub = URLSession.shared.dataTaskPublisher(for: url)
let hotPub = coldPub.share() // Теперь значения не переиздаются

// Hot -> Cold: используем multicast() с ConnectablePublisher
let hotSubject = PassthroughSubject<Int, Never>()
let connectable = hotSubject.multicast(subject: PassthroughSubject())

Практическое применение в iOS

Cold Publisher лучше использовать для:

• Сетевых запросов (каждый подписчик должен получить полный ответ)
• Операций с базой данных
• Преобразования данных, где нужна полная последовательность

Hot Publisher лучше использовать для:

• Событий пользовательского интерфейса
• Общего состояния приложения (например, через @Published)
• Реального времени (чат, уведомления)
• Таймеров и периодических задач

Понимание различий между Cold и Hot Publisher критически важно для правильного проектирования реактивных систем в iOS, так как влияет на:

1. Поведение данных — что получат подписчики
2. Производительность — избегание ненужных повторных вычислений
3. Ресурсы — управление памятью и соединениями
4. Предсказуемость — гарантии получения данных

В Combine большинство издателей по умолчанию являются Cold, а Hot обычно создаются через Subject или преобразуются операторами вроде share() и multicast().