Расскажите про Subject в RxJS — какие виды Subject знаете?

Что такое Subject?

Subject в RxJS — это гибрид Observable и Observer. Он позволяет не только подписываться на поток данных, но и активно в него эмитить значения. Это делает его удобным инструментом для организации обмена данными между компонентами или модулями приложения, особенно в реактивных архитектурах.

Основные виды Subject

• Subject — базовый тип, не хранит предыдущие значения. Новый подписчик получает только те значения, которые будут эмититься после его подписки.
• BehaviorSubject — хранит последнее значение и передает его новому подписчику сразу при подписке. Требует начальное значение при создании.
• ReplaySubject — хранит буфер последних N значений (или значений за определенный промежуток времени) и передает их новым подписчикам.
• AsyncSubject — эмитит только последнее значение, но только после завершения потока. Полезен для операций, результат которых известен только в конце.

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

import { Subject, BehaviorSubject, ReplaySubject, AsyncSubject } from 'rxjs';

// Обычный Subject
const subject = new Subject();
subject.subscribe(v => console.log('Subject:', v));
subject.next(1); // подписчик получит 1

// BehaviorSubject
const behavior = new BehaviorSubject(0);
behavior.subscribe(v => console.log('Behavior:', v)); // сразу получит 0
behavior.next(1); // получит 1

// ReplaySubject с буфером на 2 значения
const replay = new ReplaySubject(2);
replay.next(1);
replay.next(2);
replay.subscribe(v => console.log('Replay:', v)); // получит 1 и 2

// AsyncSubject
const async = new AsyncSubject();
async.subscribe(v => console.log('Async:', v));
async.next(1);
async.next(2);
async.complete(); // подписчик получит только 2

Где применяется

Subject часто используется для создания сервисов обмена данными в Angular (например, для управления состоянием), для обработки событий пользовательского интерфейса, а также для реализации шины событий в приложениях. BehaviorSubject удобен для хранения текущего состояния (например, авторизации пользователя), ReplaySubject — для кэширования последних данных, AsyncSubject — для получения результата асинхронной операции.

Вывод: Выбор конкретного типа Subject зависит от задачи: если нужно передавать только новые значения — используйте Subject, если нужно хранить текущее состояние — BehaviorSubject, если нужно воспроизводить историю — ReplaySubject, а если важен только финальный результат — AsyncSubject.