Блог

 import { Subject } from "rxjs";

export const chatstream$ = new Subject();
 

Подписка на subject не запускается, если я не создаю экземпляр другого useobservable const

пример: (это обновляет значения (всего 25))

    const value = useObservable(() => interval(1000).pipe(map(val => val   1)));
   const subscriptionchatstream: any = useObservable(() => chatstream$.pipe(map(val => {
        console.log(val)
        return val})));
 

если я не добавлю значение, в подписке будет только 1 запись.(случай ошибки, поэтому содержимое потока чатов отсутствует и не обновляется)

 const subscriptionchatstream: any = useObservable(() => chatstream$.pipe(map(val => {
            console.log(val)
            return val})));
 

Как я могу заставить подписку обновляться при каждом новом обновлении без ошибок?