退订条件不允许在 Angular RXJS 中订阅

Question

我有一项服务可以显示佩戴情况、信息和错误通知。有时通知来得很频繁。让我们同时说 20-30，我试图通过在特定时间间隔发生时取消订阅来避免这种情况。

取消订阅后无法再订阅。

  const locationsSubscription = this.messageService
      .getMessage()
      .pipe(timeInterval(), tap(console.log))
      .subscribe(message => {    
        if (message.interval < 500) {          
          locationsSubscription.unsubscribe();
        }
        else {
             switch (message.type){       
            case MessageType.Info:
              this.showInfo(message.text);
              break;
            case MessageType.Warning:
              this.showWarning(message..text);
              break;
            case MessageType.Error:
              this.showError(message.value);
              break;
          }
        }
      });

Answer 1

只需使用debounceTime或throttleTime在一段时间后触发警告：

this.messageService
      .getMessage()
      .pipe(
         debounceTime(500) // to allow messages to trigger after 500ms of inactivity (idle)
         // throttleTime(500) // to allow only one message per 500ms (first or last)
      )

退订条件不允许在 Angular RXJS 中订阅

Unsubscribe in a condition does not allow to subscribe in Angular RXJS

angular

rxjs

subscription

unsubscribe