ребят, вопрос, насколько адекватно делать каждый раз вот так, вместо
.next(product)

Так каждый раз ссылка новая будет

Почему next не устраивает?

Так каждый раз ссылка новая будет

Почему next не устраивает?

Это понятно. Но это может что-то поломать

Ну может в теории аукнутся где угодно) плюс пользователи этого кода не зная этой особенности могут использовать неправильно его

Мне нуэно передавать в сам Subject product каждый раз. Я не могу передать null, это всё сломает.

А продукт у меня только внутри .subscribe

Но каких-то утечек с аккамулируемым сасбскрибшн быть не должно, так?

Но каких-то утечек с аккамулируемым сасбскрибшн быть не должно, так?

А ансасбскрибшн есть?

Прошу прощения, что встреваю в обсуждение.

Первое, на что прошу обратить внимание: никогда не нужно допускать подобных конструкций, когда из subscribe или tap идет запись данный в текущий контекст. Например, когда делается subscribe((data) => this.data = data)this.data = data).

Второе, не надо делать подписки в подписке. Когда делается любая подписка, то необходимо позаботиться, чтобы ее уничтожить. Например, .subscribe((data) => smth.subscribe(() => …)).

И вот как решить эти проблемы.

Не делайте подписок. Даже если очень хочется, старайтесь их избегать. Да, есть ситуации, когда необходимо сделать их, но в данном случае она не требуется.
https://t.me/angular_fox/81

Используйте AsyncPipe для того, чтобы минимизировать количество необходимых подписок. Тут потребуется понимание, что такое multicasting.
https://t.me/angular_fox/73

Используйте switchMap, mergeMap, concatMap, exhaustMap, чтобы не делать внутренних подписок. Это 4 разные стратегии работы с вложенными потоками.
https://t.me/angular_fox/96
https://blog.angularindepth.com/11e5b2efe293

И самое главное, работая с RxJS всегда необходимо оперировать потоками.

Теперь, учитывая все выше перечисленное, итоговый код может выглядеть следующим образом:

user: Observable<User> =
  userService.getUser().pipe(
    filter(notNull));

userId: Observable<number> =
  user.pipe(
    pluck(‘id’));

userInfo: Observable<UserInfo> =
  userId.pipe(
    switchMap((userId) => userService.getUser(userId)));

И все что осталось сделать, это отобразить пользователя в шаблоне, если требуется. Просто воспользуемся AsyncPipe, и выведем в виде json:
<pre>{{ userInfo | async | json }}</pre>

Для начала, вот это будет хорошим ответом, так как он уже покрывает большинство проблем с этим кодом.

Хорошей практикой является оставлять потоки целостными. И если хочется, как-то изменить поток, то ему надо дать команду сверху (Subject.next). Поэтому создавать новый BehaviorSubject не стоит.

Скорее всего вы хотели сделать multicasting, и есть уже готовые операторы для этого, например shareReplay({ refCount: true, bufferSize: 1 }).