Rxjs Subject вызывается следующим, нет журнала консоли

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

const state$ = new Subject();

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

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

Вы не подписаны :) state$.pipe(tap(ev => log(ev))).subscribe()

Julius 21.05.2019 19:05
Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией
Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией
В JavaScript одним из самых запутанных понятий является поведение ключевого слова "this" в стрелочной и обычной функциях.
Концепция локализации и ее применение в приложениях React ⚡️
Концепция локализации и ее применение в приложениях React ⚡️
Локализация - это процесс адаптации приложения к различным языкам и культурным требованиям. Это позволяет пользователям получить опыт, соответствующий...
Улучшение производительности загрузки с помощью Google Tag Manager и атрибута Defer
Улучшение производительности загрузки с помощью Google Tag Manager и атрибута Defer
В настоящее время производительность загрузки веб-сайта имеет решающее значение не только для удобства пользователей, но и для ранжирования в...
Безумие обратных вызовов в javascript [JS]
Безумие обратных вызовов в javascript [JS]
Здравствуйте! Юный падаван 🚀. Присоединяйся ко мне, чтобы разобраться в одной из самых запутанных концепций, когда вы начинаете изучать мир...
Система управления парковками с использованием HTML, CSS и JavaScript
Система управления парковками с использованием HTML, CSS и JavaScript
Веб-сайт по управлению парковками был создан с использованием HTML, CSS и JavaScript. Это простой сайт, ничего вычурного. Основная цель -...
JavaScript Вопросы с множественным выбором и ответы
JavaScript Вопросы с множественным выбором и ответы
Если вы ищете платформу, которая предоставляет вам бесплатный тест JavaScript MCQ (Multiple Choice Questions With Answers) для оценки ваших знаний,...
0
1
72
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

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

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

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

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

Другие вопросы по теме