У меня есть этот кодовая ручка, и идея проста, каждый раз, когда я звоню next
на Subject
, я хочу это зарегистрировать. Я делаю это через трубу:
const state$ = new Subject();
state$.pipe(tap(ev => log(ev)));
state$.next('hello')
Чего мне не хватает, чтобы это произошло?
Результатом выражения state$.pipe(tap(ev => log(ev)));
является поток (Observable). Вы можете подписаться на стрим:
state$.pipe(tap(ev => log(ev))).subscribe();
или сохранить на потом в переменной:
const logger$ = state$.pipe(tap(ev => log(ev)));
...
logger$.subscribe()
Вы не подписаны :)
state$.pipe(tap(ev => log(ev))).subscribe()