Когда я запускаю следующий фрагмент RxJS в моем серверном приложении Express.js, наблюдаемый интервал никогда не останавливается.
Я пытался запустить его в отдельном файле вне приложения, и он работал просто отлично. Кто-нибудь может мне это объяснить?
interval(1000)
.pipe(tap(() => console.log('foo')))
.subscribe({next() { console.log('bar')}})
.unsubscribe()
результат:
foo
foo
foo
...
ожидаемый результат: ничто:)
РЕДАКТИРОВАТЬ: приведенный выше код просто бессмысленное упрощение, чтобы проиллюстрировать проблему. Мой оригинальный код делал периодические запросы к определенной конечной точке. Я обнаружил, что когда я отписываюсь от наблюдаемого (через некоторое время), запрос конечной точки никогда не прекращается.