如何从订阅服务器函数中获取返回值？

Question

我正在调用一个函数，其中有一个订户函数。此函数必须返回一个数组，但它给出了一个错误：

缺少订阅。

get():obeservable<cat[]>{
       return this.service.getsamples().subscriber(response=>{
              return <cat[]>(response);
       });
}

getSamples(){
       return this.http.get(this.url)
            .map(response=>{
             return <cat[]>response
            });
}

如何做到这一点？

Answer 1

简单的可观察设置类似于：

@Injectable()
export class SomeService {
  constructor(private readonly httpClient: HttpClient) {}

  public getData(): Observable<Cat[]> {
    return this.httpClient.get<Cat[]>('http://something.com')
      .pipe(catchError(err) => this.handleError(err));
  }

  private handleError(err: HttpErrorResponse): Observable<Cat[]> {
    // do something
    const result: Cat[] = [];
    return of(result);
  }
}

并连接到它：

@Component({...})
export class SomeComponent implements OnDestroy {
  constructor(private readonly service: SomeService) {}

  public doSomething(): void {
    this.service.getData()
      .subscribe((x: Cat[]) => {
        alert(`Received ${x.length} cats`);
      });
  }
}

在某种程度上，Angular HttpClient变得更加智能，可以处理返回类型的映射，因此您可以创建自己的通用HttpService，并使用this.HttpClient.get

Answer 2

首先，如果要将数据返回从一个可观察对象映射到其他对象，请将map（）操作符传递到可观察对象的管道。这样地：

getSamples(): Observable<Cat[]>{
  return this.http.get(this.url).pipe(map(response => { .... });
}

但是如果get请求只是返回Cat[]数据，那么您不必映射它：

getSamples(): Observable<Cat[]>{
  return this.http.get(this.url);
}

其次，如果要激活从getSamples（）返回的可观察对象，subscribe（）将其激活，而不是subscriber（）将其激活。

知道subscribe（）函数将返回您所包含的可观察对象的订阅，而不是它包含的数据，这一点非常重要

从函数内部的可观察对象返回数据不是一个好方法，因为get（）是一个异步函数，它需要等待http请求首先完成，才能返回正确的数据/错误。因此，更好的方法是激活外部某处的可观察对象，并将需要cat[]数据的逻辑传递给它：

ngOnInit() {
   this.service.getsamples().subscribe(response => {
       console.log(response) 
      // Do stuffs with respone data
   },err =>{
      console.log(err)
      // Do things with error
   });
}