Rxjs субъект вызвал следующий нет консоли журнала

Question

У меня есть codepen , и идея проста, каждый раз, когда я звоню next на Subject, я хочу записать это. Я делаю это через трубу:

const state$ = new Subject();

state$.pipe(tap(ev => log(ev)));
state$.next('hello')

Чего мне не хватает, чтобы это произошло?

Answer 1

Результатом выражения state$.pipe(tap(ev => log(ev))); является поток (наблюдаемый). Вы можете подписаться на поток:

state$.pipe(tap(ev => log(ev))).subscribe();

или сохранить на потом в переменной:

const logger$ = state$.pipe(tap(ev => log(ev)));
...
logger$.subscribe()