Я не нашел маркер для разбора в процессе. Ни .isClosed
, ни .isStopped
не подходит. Но я решил свою проблему, отписавшись от Subject
каждый раз внутри подписки. В этом случае подписка существует только в диапазоне отклонения прогресса, а в остальное время .next()
ничего не делает.
let subscription = this.resizeDebouncer
.pipe(debounceTime(300))
.subscribe(e => {
subscription.unsubscribe();
e => console.log(e.type);
});