Какой тип Subject сохраняет последнее отправленное значение и передает его новым подписчикам в RxJava?

BehaviorSubject в RxJava

В RxJava тип Subject, который сохраняет последнее отправленное значение и передает его новым подписчикам при их подключении, называется BehaviorSubject.

Основные характеристики BehaviorSubject

• Хранение последнего значения: BehaviorSubject сохраняет текущее (последнее отправленное) значение в своем внутреннем состоянии.
• Передача новым подписчикам: Когда новый подписчик (Observer) присоединяется к BehaviorSubject, он немедленно получает это последнее сохраненное значение (или начальное значение, если оно было задано), если оно существует. После этого он продолжает получать все новые события, как обычный Observable.
• Инициализация с начальным значением: BehaviorSubject можно создать с начальным значением, которое будет первым событием для всех подписчиков, присоединившихся до первого вызова onNext().

Пример создания и использования BehaviorSubject

// Пример на Kotlin с RxJava
import io.reactivex.rxjava3.subjects.BehaviorSubject

fun main() {
    // Создание BehaviorSubject с начальным значением
    val subject = BehaviorSubject.createDefault("Начальное значение")

    // Первый подписчик получает начальное значение сразу
    subject.subscribe { value ->
        println("Подписчик 1 получил: $value")
    }

    // Отправляем новое значение
    subject.onNext("Первое событие")

    // Второй подписчик присоединяется после отправки события
    // Он получает последнее сохраненное значение ("Первое событие")
    subject.subscribe { value ->
        println("Подписчик 2 получил: $value")
    }

    // Отправляем еще одно значение, оба подписчика получают его
    subject.onNext("Второе событие")

    // Третий подписчик присоединяется сейчас и получает последнее значение ("Второе событие")
    subject.subscribe { value ->
        println("Подписчик 3 получил: $value")
    }

    // Завершаем Subject
    subject.onComplete()

    // После onComplete() новые подписчики не получают значений, только событие завершения
    subject.subscribe(
        { value -> println("Подписчик 4 (после завершения) получил: $value") },
        { error -> println("Ошибка: $error") },
        { println("Завершено") }
    )
}

Вывод программы будет следующим:

Подписчик 1 получил: Начальное значение
Подписчик 1 получил: Первое событие
Подписчик 2 получил: Первое событие
Подписчик 1 получил: Второе событие
Подписчик 2 получил: Второе событие
Подписчик 3 получил: Второе событие
Завершено

Сравнение с другими типами Subject

• PublishSubject: Не хранит никаких значений. Новые подписчики получают только события, отправленные после их подключения.
• ReplaySubject: Хранит в буфере все отправленные значения (или заданное количество) и передает их новым подписчикам. Это более "тяжелый" вариант, чем BehaviorSubject.
• AsyncSubject: Сохраняет только последнее значение, но передает его подписчикам только при вызове onComplete().

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

BehaviorSubject чрезвычайно полезен в Android разработке для создания реактивных моделей данных, которые должны предоставлять текущее состояние новым потребителям.

// Пример: реактивная модель состояния пользователя
class UserSessionManager {
    // BehaviorSubject хранит текущее состояние авторизации
    private val authStateSubject = BehaviorSubject.createDefault<AuthState>(AuthState.Unknown)

    // Публичный Observable для подписки компонентов
    val authStateObservable: Observable<AuthState> = authStateSubject.hide()

    fun updateAuthState(state: AuthState) {
        authStateSubject.onNext(state)
    }

    fun getCurrentState(): AuthState? {
        return authStateSubject.value // Получение текущего значения без подписки
    }
}

enum class AuthState {
    Unknown, LoggedOut, LoggedIn
}

// В Activity/Fragment или ViewModel
class MainViewModel(private val sessionManager: UserSessionManager) {
    init {
        // Подписываемся на состояние. Получим текущее значение сразу и все будущие изменения
        sessionManager.authStateObservable
            .subscribe { state ->
                updateUI(state)
            }
    }

    private fun updateUI(state: AuthState) {
        // Обновление интерфейса в зависимости от состояния
    }
}

BehaviorSubject является идеальным выбором, когда вам требуется "реактивная переменная с памятью" — поток, который всегда имеет текущее значение и готов предоставить его любому новому наблюдателю. Это делает его ключевым инструментом для управления состоянием в современных Android приложениях, построенных на реактивных принципах.