constructor(private http: HttpClient) {
super();
this.product$ = Observable.timer(0, 3000)
.pipe(
exhaustMap(() => {
return this.http
.get<Product>(`${this.tradeEndpoint}/products`)
.pipe(
map((product: Product) => product)
);
}),
share()
);
}
ругается на - Type 'Observable<Product>' is not assignable to type 'EventEmitter<Product>'.
Property '__isAsync' is missing in type 'Observable<Product>'.
ну если ты хочешь там что-то эмитить то подпишись '.subscribe((response: Product) => this.product.emit(response))' а назначение this.product$, ты эммитер назначаешь Observable stream
Обсуждают сегодня