过滤BehaviourSubject.asObservable()问题
Filtering BehaviourSubject.asObservable() problem
我正在通过 HttpClient 加载数据并将它们发布为 BehaviourSubject:
export interface Car {
id:number;
make: string;
status: number;
}
在服务中,我通过 API 端点加载数据:
private cars = new BehaviorSubject<Car[]>([]);
constructor( private http: HttpClient) {
this.loadCars();
}
loadCars() {
this.http.get<Car[]>('/api/cars')
.subscribe((cars) => this.cars.next(cars));
}
getFilteredCars() {
return this.cars.asObservable()
.pipe(
map( (cars) => cars.filter( car => car.status === 1)
)
);
}
如您所见,我想要获得状态等于 1 的所有汽车。
当我从我的组件调用它时,我没有得到任何东西:
Component
cars: Observable<Car[]>;
constructor(private carService: CarService) {
this.cars = carService.getFilteredCars();
}
我正在获取未经过滤的数据,没有任何问题如果我返回未经过滤的 BehaviourSubject:
getFilteredCars() {
return this.cars.asObservable();
}
我做错了什么?
我怀疑您需要订阅从 getFilteredCars() 方法返回的可观察对象。
carService.getFilteredCars().subscribe(data=>this.cars = data);
我正在通过 HttpClient 加载数据并将它们发布为 BehaviourSubject:
export interface Car {
id:number;
make: string;
status: number;
}
在服务中,我通过 API 端点加载数据:
private cars = new BehaviorSubject<Car[]>([]);
constructor( private http: HttpClient) {
this.loadCars();
}
loadCars() {
this.http.get<Car[]>('/api/cars')
.subscribe((cars) => this.cars.next(cars));
}
getFilteredCars() {
return this.cars.asObservable()
.pipe(
map( (cars) => cars.filter( car => car.status === 1)
)
);
}
如您所见,我想要获得状态等于 1 的所有汽车。 当我从我的组件调用它时,我没有得到任何东西:
Component
cars: Observable<Car[]>;
constructor(private carService: CarService) {
this.cars = carService.getFilteredCars();
}
我正在获取未经过滤的数据,没有任何问题如果我返回未经过滤的 BehaviourSubject:
getFilteredCars() {
return this.cars.asObservable();
}
我做错了什么?
我怀疑您需要订阅从 getFilteredCars() 方法返回的可观察对象。
carService.getFilteredCars().subscribe(data=>this.cars = data);