等待 observable 中的其他 observable 响应。角度异步

Question

我想实现什么目标？

• 我有多个组件具有几乎相同的检查和数据操作..我想将它们转移到可观察中..
• 我在我的服务中创建了一个可观察名称“getData”...
• 不同的是“getdata”有一个 if 检查.. - > 如果本地存储有数据则返回数据。 如果没有，则从 api 调用（getbyid）请求数据，然后操作它并返回数据。

注意：我们无法更改 getbyid（）。他们都在同一个服务中。

API

  getbyid(id: any): Observable<any> {
    return this.http.post<any>(this.serverurl, id )
    .pipe(tap((res) => { return res })); 

     
  }

我的代码

getData(origin: any, id:number):Observable<any> {
    let data= new BehaviorSubject({});
    if(origin=='main page'){
    let localstorage= this._aes.getItem('localstorage')

    if(!localstorage){  
      
      console.log('before api');
     
        this.getbyid(id).subscribe(res=>{
          console.log('res',res);
          data.next(res)
          return data.asObservable()
         })
      console.log('after api');
        
    }else{
      data.next({data:payload})
      return data.asObservable()
    }

    }
     
  }

当前场景：它只是点击 getbyid 而不是等待响应并继续...如果我们以某种方式让它等待响应，这可以解决。

Answer 1

在这种情况下你不需要BehaviorSubject。
像这样的东西应该可以工作（我认为“有效负载”是您存储的内容？）：

  getbyid(id: any): Observable<any> {
    return this.http.post<any>(this.serverurl, id));         
  }

  getData(origin: any, id: number): Observable<any> {
    if (origin !== 'main page') {
      return EMPTY;
    }

    const payload = this._aes.getItem('localstorage');
    return payload ? of(payload) : this.getById(id);
}

如果设置了有效负载，我们将返回一个可观察的值。如果没有，则为带有后端调用的可观察对象。

在这两种情况下，您都必须从调用 getData 方法的位置进行订阅并等待响应。