等待过滤器完成

Question

是否可以等待过滤功能完成？

我在 Angular 6 中有这个 observable，在那里我做了一个过滤器。过滤器需要几秒钟，所以做一些功能会很好，当过滤器完成时。这可能吗？

flSearch(input) {
    return this._plantCache.pipe( // Use downloaded JSON file
            map(
              (res: Array<Object>) => {
                return res.filter(item => {
                  return item['Fl'].indexOf(fl) !== -1;
                });
              },
              error => {
                this.loadingHide();
                return error;
              })
            );
}

其他文件

this._data.flSearch(data.value.searchPlant)
            .subscribe(items => {
              console.log(items);
            });

Answer 1

你可以让你的函数返回一个可观察的https://angular.io/guide/observables

import {Observable} from 'rxjs/Observable';

flSearch(input) {
    return new Observable ((observer) => {
      observer.next(this._plantCache.pipe( // Use downloaded JSON file
        map((res: Array<Object>) => {
          return res.filter(item => {
            return item['Fl'].indexOf(fl) !== -1;
          });
        }, error => {
          this.loadingHide();
          return error;
        })
      ));
    });
  }

编辑：observer.next() 用于返回值，observer.complete() 关闭 observable，这样它就不会在完成工作后耗尽内存。您必须导入 rxjs 才能访问可观察实例。