POST操作后如何订阅创建对象的Id

Question

我有一个组件，我通过像这样调用api 添加一个名为customer 的新对象：

  public onAdd(): void {
    this.myCustomer = this.customerForm.value; 
    this.myService.addCustomer(this.myCustome).subscribe(
      () => {  // If POST is success
        this.callSuccessMethod(); 
      },
      (error) => { // If POST is failed
       this.callFailureMethod();
      },
    );

 }

服务文件：

import { HttpClient } from '@angular/common/http';
import { Injectable } from '@angular/core';
import { Observable, Subject } from 'rxjs';
import {ICustomer } from 'src/app/models/app.models';

@Injectable({
  providedIn: 'root',
})

export class MyService {
 private  baseUrl : string = '....URL....';
 constructor(private http: HttpClient) {}


public addCustomer(customer: ICustomer): Observable<object> {
  const apiUrl: string = `${this.baseUrl}/customers`;

  return this.http.post(apiUrl, customer);
}

}

如组件代码所示，我已经订阅了api这样的调用：

this.myService.addCustomer(this.myCustome).subscribe(
          () => {  // If POST is success
            .....
          },
          (error) => { // If POST is failed
           ...
          },
        );

但是，我想在另一个组件中订阅结果，我试过这样：

public  getAddedCustomer() { 
    this.myService.addCustomer().subscribe(
      (data:ICustomer) => { 
        this.addedCustomer.id = data.id; <======
      }
    );
  }

我收到这个 lint 错误：Expected 1 arguments, but got 0，因为我没有传递任何 parameter。

在其他组件中订阅 api 调用的正确方法是什么？ POST 操作后。

因为我想为其他功能添加对象 ID。

Answer 1

这完全取决于您的应用程序的设计和组件之间的关系。您可以使用主题将数据多播给多个订阅者。

import { HttpClient } from '@angular/common/http';
import { Injectable } from '@angular/core';
import { Observable, Subject } from 'rxjs';
import { ICustomer } from 'src/app/models/app.models';

@Injectable({
  providedIn: 'root',
})

export class MyService {
 private  baseUrl : string = '....URL....';
 private latestAddedCustomer = new Subject();
 public latestAddedCustomer$ = this.latestAddedCustomer.asObservable()
 constructor(private http: HttpClient) {}


public addCustomer(customer: ICustomer): Observable<object> {
  const apiUrl: string = `${this.baseUrl}/customers`;

  return this.http.post(apiUrl, customer).pipe(map((data) => this.latestAddedCustomer.next(data)));
}

}

并订阅主题如下

this.latestAddedCustomer$.subscribe()

应该会为您提供最新添加的客户详细信息。即使我不会按照它的书面方式这样做。我基本上会编写一个单独的服务来共享组件之间的数据，或者如果它在整个应用程序中使用，我会编写一个缓存服务。但这里的想法是使用主题的概念。你可以阅读更多关于它Here