这篇文章主要介绍了angular请求防抖及处理第一次请求失效的相关资料,需要的朋友可以参考下
问题：
根据项目中的需求，需要设计一个下拉框，在输入时根据内容提供实时的建议，在此我们使用了如下组件，
因为我们需要根据输入内容实时的查询后台返回结果，如果每次更改都要传给后台的话，太耗费资源，而且对用户也不友好，为此我们采用了angular的请求防抖做处理,代码如下。
packages$: Observable; private searchText$ = new Subject(); search(packageName: string) { this.searchText$.next(packageName); } ngOnInit() { this.packages$ = this.searchText$.pipe( debounceTime(500), distinctUntilChanged(), switchMap(packageName => this.searchService.search(packageName, this.withRefresh)) ); }
作用如下：
debounceTime(500) – 等待，直到用户停止输入（这个例子中是停止 1/2 秒）。
distinctUntilChanged() – 等待，直到搜索内容发生了变化。
switchMap() – 把搜索请求发送给服务。
但当我们使用的时候发现在初始化第一次请求的时,并不会调用service的方法，错误代码如下：
private searchText$ = new Subject(); packages$: Observable; ngOnInit() { // 创建可观察着对象 this.packages$ = this.searchText$.pipe( debounceTime(500), distinctUntilChanged(), switchMap(packageName => this.instrumentAliasService.queryInstrumentAliasByName(packageName)) ); } this.searchText$.next(this.queryName); this.packages$.subscribe((instrumentAliases: Array) => { this.filteredinstrumentAlias = instrumentAliases; }, () => { console.log('get instrumentAliases error'); });
searchText$ 是一个序列，包含用户输入到搜索框中的所有值。 它定义成了 RxJS 的 Subject 对象，这表示它是一个多播 Observable，同时还可以自行调用 next(value) 来产生值，在上面错误的代码中，因为我们先调用的时next方法，这是虽然产生了值，但是还没有进行订来源gao.dai.ma.com搞@代*码网阅，所以第一次的值并不会向后台发起请求，而之后因为我们已经订阅了这个东西，所以第一次请求之后的请求都有效果。
结果方法：
在初始化的时候就进行订阅，这样在之后的查找我们只需要使用next传值即可，我们已订阅的对象就会自动触发后台请求。
总结：
写功能的时候只是简单的对代码进行复制粘贴，并没有真正的理解angular的观察者的设计机制，通过这个错误加深了对angular观察者的理解。
如果你觉得本文对你有帮助，欢迎转载，烦请注明出处，谢谢！
以上就是Angular请求防抖处理第一次请求失效问题的详细内容，更多请关注gaodaima搞代码网其它相关文章！
转载请注明原文链接：Angular请求防抖处理第一次请求失效问题
