ДМ
я бы это отдельной подпиской сделал, а общий код потока до этого места - вынес бы в отдельный Observable. Если вынести общий код, то можно избавиться и от лишего сабжекта с вызовом next(и подписка даже не понадобится)
например:
--- better ----
и вот мы уже вместа сабжекта можем использовать
obs.pipe(
...operators,
tap(() => sub.next() )
)
--- better ----
const anotherObs = obs.pipe(
...operators
).shareReplay({ refcount: true })и вот мы уже вместа сабжекта можем использовать
anotherObs