javascript - 如何在 RxJs 中满足条件后立即取消订阅

Question

我是 RxJs 可观察对象的新手，一旦满足条件，我发现很难取消订阅循环，请你帮我

在下面的函数中，如果代码到达 if block 我想取消订阅 Observables

在问这个问题之前，我已经经历了以下问题，但没有一个对我有太大帮助

Rxjs observable wait until some condition is met

AngularJs - RXJS Observable unsubscribe

Javascript函数

this.router.events.subscribe((url: any) => {
    url = this.router.url;
    if ((url === "/profile" || url === "/summary") && this.filterConfigFlag === false) {

        /*
        Perform operations
        */

    } else {
        console.log(typeof (url), url);

    }
});

Answer 1

你可能想要 takeWhile :

this.router.events
  .pipe(
    takeWhile(url => url === ...), // when the condition isn't met it'll complete immediately
  )
  .subscribe(...);

但如果您还想包含最后一个值(完成 Observable 的值)，您需要执行以下操作:

在 RxJS 6.4 之前

this.router.events
  .pipe(
    concatMap(url => url === ... ? of(url, null) : of(url)),
    takeWhile(Boolean),
  )
  .subscribe(...);

从 RxJS 6.4 开始

RxJS 6.4 向 takeWhile 添加了重载，现在可以像这样包含最后一个值:

this.router.events
  .pipe(
    takeWhile(url => url === ..., true),
  )
  .subscribe(...);