Что такое Subject Publisher?

Что такое Subject Publisher в Combine

Subject Publisher — это специальный тип Publisher в фреймворке Combine от Apple, который позволяет не только распространять (publish) значения, но и внешним образом отправлять (send) эти значения в поток данных. В отличие от обычных Publisher, которые являются read-only и предоставляют готовую последовательность событий, Subject действует как мост между императивным и реактивным кодом, позволяя "вручную" передавать значения, ошибки и события завершения.

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

• Mutable State: Subject имеет изменяемое состояние — вы можете отправлять новые значения (send(_:)).
• Двойная роль: Он одновременно является и Publisher (подписчики могут получать значения), и Subscriber (может принимать значения через send).
• Hot по природе: Subject является "горячим" (Hot Publisher) — он начинает испускать значения сразу, независимо от наличия подписчиков. Если подписчик присоединится позже, он получит только будущие значения.

Основные типы Subject в Combine

В Combine существует три основных типа Subject:

1. PassthroughSubject

Просто передаёт значения "сквозь себя" подписчикам. Не хранит текущее значение. Новые подписчики получают только значения, отправленные после подписки.

import Combine

let subject = PassthroughSubject<String, Never>()

// Подписчик 1
let subscription1 = subject.sink { value in
    print("Подписчик 1 получил: \(value)")
}

subject.send("Привет") // Напечатает: "Подписчик 1 получил: Привет"

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

subject.send("Мир") // Напечатает для обоих подписчиков
// Подписчик 2 НЕ получит "Привет", так как подписался позже

2. CurrentValueSubject

Хранит текущее значение (currentValue) и отправляет его новым подписчикам сразу при подписке. Это делает его похожим на реактивную переменную (observable property).

import Combine

let currentSubject = CurrentValueSubject<Int, Never>(0) // Начальное значение 0

// Подписчик получит текущее значение (0) сразу
let subscription = currentSubject.sink { value in
    print("Получено: \(value)")
}

currentSubject.send(1) // Напечатает: "Получено: 1"
currentSubject.value = 2 // Альтернативный способ отправки (меняет .value)

3. Subject как протокол

Также существует протокол Subject, который могут реализовывать пользовательские типы.

Практическое применение Subject Publisher

1. Мост между императивным и реактивным кодом: Например, при обработке действий пользователя (нажатия кнопок) в UIKit/SwiftUI.

class ViewModel {
    let buttonTappedSubject = PassthroughSubject<Void, Never>()
    
    func buttonTapped() {
        buttonTappedSubject.send(())
    }
}

1. Состояние приложения/модуля: CurrentValueSubject часто используется для хранения изменяемого состояния.

class UserSession {
    private let isLoggedInSubject = CurrentValueSubject<Bool, Never>(false)
    var isLoggedInPublisher: AnyPublisher<Bool, Never> {
        isLoggedInSubject.eraseToAnyPublisher()
    }
    
    func login() {
        // Логика входа
        isLoggedInSubject.send(true)
    }
}

1. Адаптация существующих делегатов или callback-ов: Преобразование делегатных методов в поток Combine.

2. Тестирование: Создание мок-издателей для тестирования реактивных цепочек.

Отличие от обычного Publisher

Важные нюансы использования

• Управление памятью: Subject хранит ссылки на подписчиков, поэтому важно управлять жизненным циклом подписок (через AnyCancellable).
• Завершение потока: Можно явно завершить Subject с помощью send(completion:).
• Потокобезопасность: Большинство Subject потокобезопасны — можно отправлять значения из разных очередей.
• Преобразование в тип-erased: Часто используют eraseToAnySubject() для сокрытия конкретного типа.

Subject Publisher — это мощный инструмент, который делает Combine гибким и применимым в реальных iOS-приложениях, позволяя интегрировать реактивное программирование с существующим императивным кодом. Однако его следует использовать осознанно, так как чрезмерное применение может привести к сложностям в отладке и нарушению чистой реактивной архитектуры.