在RxJs中满足条件后如何立即退订

Question

我是RxJ观察站的新手，一旦满足条件，我将难以取消订阅循环，请您帮我一下

在下面的函数中，如果代码到达if块，我想退订Observables

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

1. Rxjs可观察到，直到满足某些条件
2. AngularJs-RXJS可观察的退订

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(...);