Angular / RxJs对一个observable的多个订阅
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Angular / RxJs对一个observable的多个订阅相关的知识,希望对你有一定的参考价值。
我正在尝试构建一个复杂的反应形式,我需要根据其他2个下拉的值填充一个下拉列表。我已经弄清楚如何在更改一个下拉列表时从服务获取值。但它不适用于2,因为第二个订阅取代了第一个订阅。我是否需要找到一种同步方式来填充第3个下拉列表?这就是我现在拥有的:
constructor(private fb: FormBuilder, private defectsService: DefectsService) {
this.searchForm = fb.group(this.searchCriteria);
...
this.tradeParners$ = this.setupCascadingDropDown('community', (communityId: number) => {
let tradePartnerData$ = this.defectsService
.getTradePartners(communityId, this.searchForm.get('jobSite').value);
this.tradeParnersSubscription = tradePartnerData$.do((x) =>
console.log(`${x} trade partners`)
).subscribe();
return tradePartnerData$;
});
this.tradeParners$ = this.setupCascadingDropDown('jobSite', (jobId: number) => {
let tradePartnerData$ = this.defectsService
.getTradePartners(this.searchForm.get('community').value, jobId);
this.tradeParnersSubscription = tradePartnerData$.subscribe();
return tradePartnerData$;
});
}
private setupCascadingDropDown(controlName: string, getData): Observable<ISelectItem[]> {
let control = this.searchForm.get(controlName);
return control.valueChanges
.do(test => console.debug(`${controlName}: ${test}`))
.distinctUntilChanged()
.switchMap(getData);
}
有什么方法可以在一个事件触发时订阅一个observable并在另一个事件触发时替换它?
更新
这是填充使用observable的下拉列表的代码。
<label class="col-sm-2 col-md-2 control-label">Trade Partner:</label>
<div class="col-sm-3 col-md-3">
<select class="hbp-defect-select" formControlName="tradePartner">
<option value="-1">- All -</option>
<option *ngFor="let tp of tradePartners$ | async" [ngValue]="tp.value">{{ tp.text }}</option>
</select>
</div>
答案
这确实很复杂,但我想我已经掌握了它。
const tradeParnersFromCommunity$ = this.setupCascadingDropDown('community', (communityId: number) => {
let tradePartnerData$ = this.defectsService
.getTradePartners(communityId, this.searchForm.get('jobSite').value);
this.tradeParnersSubscription = tradePartnerData$.do((x) =>
console.log(`${x} trade partners`)
).subscribe();
return tradePartnerDataFromJobsite$;
});
this.tradeParnersFromJobsite$ = this.setupCascadingDropDown('jobSite', (jobId: number) => {
let tradePartnerData$ = this.defectsService
.getTradePartners(this.searchForm.get('community').value, jobId);
this.tradeParnersSubscription = tradePartnerData$.subscribe();
return tradePartnerData$;
});
this.tradeParners$ = tradeParnersFromCommunity$.merge(tradeParnersFromJobsite$);
你可能也想在那里进行排序?
以上是关于Angular / RxJs对一个observable的多个订阅的主要内容,如果未能解决你的问题,请参考以下文章
Angular/RxJS 6:如何防止重复的 HTTP 请求?
在 socket.io-client 中调用 IO 时出错,角度 8
Angular Websocket RxJS / WebSocketSubject