Прервать выполнение трубы

Question

Я использую этот код для управления компонентом автозаполнения.

В этом коде ниже, как я могу прервать выполнение ".find" на основании какого-либо условия? Например, выполняется только в том случае, если какая-то переменная isOk имеет значение true.

ngOnInit() {
  this.control.valueChanges
    .pipe(
      debounceTime(300),
      tap(() => this.start()),
      switchMap(value =>
        this.modelService
          .find(this.searchUrl, this.searchField, value)
          .pipe(finalize(() => this.finalize()))
      )
    )
    .subscribe(values => this.loaded(values));
}

start() {
  .....
}

finalize() {
  .....
}

loaded(values) {
  .....
}

Answer 1

Вот что я сделал для работы:

this.control.valueChanges
  .filter(() => this.isOk)   // <==== used the filter function
  .pipe(
    debounceTime(300),
    tap(() => this.start()),
    switchMap(value =>
      this.modelService
        .find(this.searchUrl, this.searchField, value)
        .pipe(finalize(() => this.finalize()))
    )
  )
  .subscribe(values => this.loaded(values));

Answer 2

Не могли бы вы просто набрать трубку в Rx js find до вашего звонка:

ngOnInit() {
  this.control.valueChanges
    .pipe(
      debounceTime(300),
      tap(() => this.start()),
      switchMap(value =>
        this.modelService
          .pipe(find(() => this.isOk)),  // <-- like this
          .find(this.searchUrl, this.searchField, value)
          .pipe(finalize(() => this.finalize()))
      )
    )
    .subscribe(values => this.loaded(values));
}