В чем разница между Subject и BehaviorSubject в RxJS?

Основное отличие: начальное значение и "воспроизведение" последнего значения

Главное различие между Subject и BehaviorSubject в том, что BehaviorSubject:

• Всегда хранит текущее значение (последнее переданное через next())
• Требует начальное значение при создании
• Автоматически отдает последнее значение новым подписчикам

Subject же просто ретранслирует события всем текущим подписчикам, но не хранит историю. Если подписчик подключился после того, как событие произошло, он его не получит.

Как это работает на практике

Давайте перепишем ваш сервис с использованием BehaviorSubject:

import { Injectable } from '@angular/core';
import { BehaviorSubject } from 'rxjs';

@Injectable({ providedIn: 'root' })
export class UserService {
  // BehaviorSubject требует начальное значение — null означает "пользователь не авторизован"
  private userSubject = new BehaviorSubject<User | null>(null);
  user$ = this.userSubject.asObservable();

  constructor() {
    // Даже если login() никогда не вызывался, подписчики получат null
  }

  login(user: User) {
    this.userSubject.next(user);
  }

  logout() {
    this.userSubject.next(null);
  }
}

Теперь в компоненте:

export class ProfileComponent implements OnInit {
  currentUser: User | null = null;

  ngOnInit() {
    // Подписка произошла, и мы сразу получаем текущее значение
    this.userService.user$.subscribe(user => {
      this.currentUser = user;
      // Если пользователь уже вошел — получим User
      // Если нет — получим null (начальное значение)
    });
  }
}

Когда использовать Subject, а когда BehaviorSubject?

• BehaviorSubject — когда вам нужно "текущее состояние": статус авторизации, настройки приложения, данные из API, которые обновляются. Идеально для сервисов состояния (state management).
• Subject — когда важны только события, а не состояние: клики, нажатия клавиш, WebSocket сообщения, где каждое событие обрабатывается независимо.

Дополнительные отличия

• BehaviorSubject всегда можно прочитать синхронно через .getValue() (или .value в новых версиях) — получите последнее значение без подписки.
• При ошибке или завершении BehaviorSubject перестает отдавать значения, и все новые подписчики получают только ошибку/завершение.
• BehaviorSubject — частный случай ReplaySubject(1), который "воспроизводит" последние N значений.

Пример с getValue()

// Проверяем, авторизован ли пользователь, без подписки
if (this.userService.userSubject.getValue() !== null) {
  console.log('Пользователь авторизован');
}

Но лучше избегать getValue() в пользу асинхронного подхода с async пайпом в шаблонах Angular или комбинированием Observable через combineLatest.

В итоге: если вам нужно "последнее известное состояние" — используйте BehaviorSubject. Если только поток событий — Subject.

import { ReplaySubject } from 'rxjs';

// Храним последние 3 сообщения чата
const chatMessages = new ReplaySubject<string>(3);

chatMessages.next('Привет!');
chatMessages.next('Как дела?');
chatMessages.next('Что делаешь?');

// Новый подписчик получит все 3 сообщения
chatMessages.subscribe(msg => console.log(msg));
// Вывод: "Привет!", "Как дела?", "Что делаешь?"

// Еще одно сообщение
chatMessages.next('Пока!');

// Еще один подписчик получит последние 3: "Как дела?", "Что делаешь?", "Пока!"
chatMessages.subscribe(msg => console.log(msg));