如何使switchmap返回值来自早期可观察的

Question

我有一个可观察到的正在获取客户信息的可观察，我想使用客户编号查找

我需要的名称。WorkDetail$包含GetWorkItem的两个响应，这是一个可能包含客户编号的JSON对象，如果确实如此我想查找它，并将客户名称添加到可观察到的输出中，

      this.workDetail$ = this.workService
        .getWorkItem(workNumber)
        .pipe(
          iif((res: WorkItemNumberResposne) => res.customerNumber),
              //want this customer number added to main output stream          
          this.customerService.getCustomerById(res.customerNumber),
            //else nothing to do
        );

即使是正确的方法？

Answer 1

我们可以使用 switchmap this.customerService.getCustomerById（res.customernumber）将返回。我们使用 iif（） https：htttps：htttps：// wwwww。 Learnrxjs.io/learn-rxjs/operators/conditional/iif 操作员要比较， res？.customernumber！= null ||未定义的，基于这种情况，我们将返回 trueresult 或 falseresult 。

<p>Async Object</p>
<div *ngFor="let item of workDetail$ | async | keyvalue">
  {{ item.key }}:{{ item.value }}
</div>

<!-- 
id:1
item:something
name:Amber
-->

  detail = { id: 123, customerNumber: 1 };
  person = { id: 1, name: 'Amber', item: 'something' };

  workDetail$: Observable<any> = of(this.detail).pipe(
    switchMap((res) =>
      iif(() => res?.customerNumber != null || undefined, of(this.person), of(null))
    ),
    delay(1000)
  );

随意自己进行替换并消除延迟。

工作示例：

Answer 2

根据条件，请返回可观察的或另一个。您的病情是关于对可观察的响应的响应，因此我们需要使用swichmap（您将可观察到的“ workdetail”切换到可观察到的“ iif”），

如果条件已充满了状态，您可以返回可观察到的“ this.customerService.getCustomerById（res.customernumber）”，但是您转换（使用映射）以返回具有FISRT可观察的属性以及此上次可观察的属性的属性（为此，我使用传播操作员，如果只想添加新属性，您可以使用一些像 { ... res，自定义名称：customer.name}

在代码中

  workDetail$: Observable<any> = this.customerService.workDetail$.pipe(

   //we don't want this observable else the observable "iif"
    switchMap((res:any) => 

      iif(() => res.customerNumber,

          //if res.customerNumber, return the observable "getCustomerById"
           this.customerService.getCustomerById(res.customerNumber).pipe(

              //but "transformed"
              map((customer:any)=>({...res,...customer}))),

          //else simply return an observable using "of"
           of(res))
    )
  );