在Angular 6中,可以使用RxJS的操作符来处理多个重复的API调用。下面是一个示例解决方法:
首先,我们需要定义一个Subject和一个Observable来管理API调用。在你的服务文件中,添加以下代码:
import { Injectable } from '@angular/core';
import { HttpClient } from '@angular/common/http';
import { Observable, Subject } from 'rxjs';
import { debounceTime, distinctUntilChanged, switchMap } from 'rxjs/operators';
@Injectable()
export class ApiService {
private searchTerm = new Subject();
private apiUrl = 'https://api.example.com/';
constructor(private http: HttpClient) {}
search(term: string): void {
this.searchTerm.next(term);
}
getResults(): Observable {
return this.searchTerm.pipe(
debounceTime(300), // 设置延迟以避免频繁调用API
distinctUntilChanged(), // 只有当搜索词发生变化时才调用API
switchMap(term => {
const url = `${this.apiUrl}?search=${term}`;
return this.http.get(url);
})
);
}
}
在上面的示例中,我们创建了一个searchTerm
Subject来订阅搜索词的变化。当调用search()
方法时,我们向searchTerm
Subject发送搜索词。然后,我们使用RxJS的操作符来处理搜索词的变化:debounceTime
用于设置延迟以避免频繁调用API,distinctUntilChanged
用于只有当搜索词发生变化时才调用API,switchMap
用于在每次搜索词变化时调用API。
现在,在你的组件中,你可以通过订阅getResults()
方法来获取API的结果。例如:
import { Component } from '@angular/core';
import { ApiService } from './api.service';
@Component({
selector: 'app-root',
template: `
- {{ result }}
`,
providers: [ApiService]
})
export class AppComponent {
searchTerm: string;
results: any[];
constructor(private apiService: ApiService) {}
search(): void {
this.apiService.search(this.searchTerm);
this.apiService.getResults().subscribe(results => {
this.results = results;
});
}
}
在上面的示例中,我们在输入框中使用双向绑定来获取搜索词,并在每次键盘按键时调用search()
方法。search()
方法调用了search()
方法来发送搜索词,并订阅了getResults()
方法来获取API的结果。当结果返回时,我们将结果分配给results
属性,以在模板中进行显示。
这样,每当搜索词发生变化时,API调用都会被处理,以避免多次重复的调用。