我有一个小问题,我订阅了2次。按时我有正确的结果,但是有了第二个订阅,我总是有相同的结果。这是我的代码:
import { Injectable } from '@angular/core';
import { BehaviorSubject, Subject, merge, EMPTY, combineLatest, Observable, of } from 'rxjs';
import { scan, map, catchError, tap } from 'rxjs/operators';
import { boatsList } from 'src/app/shared/mocks/boats.mock';
import { CatamaranModel } from 'src/app/shared/models/catamaran.model';
import { SailBoatModel } from 'src/app/shared/models/sail-boat.model';
@Injectable({
providedIn: 'root'
})
export class BoatListService {
private boatListInitSubject: BehaviorSubject<(CatamaranModel|SailBoatModel)[]> = new BehaviorSubject(boatsList);
boatListInit$ = this.boatListInitSubject.asObservable();
private addedBoatSubject: Subject<(CatamaranModel|SailBoatModel)> = new Subject();
addedBoat$ = this.addedBoatSubject.asObservable();
boatList$: Observable<(CatamaranModel|SailBoatModel)[]> = merge(
this.boatListInit$,
this.addedBoat$
)
.pipe(
scan((acc: (CatamaranModel|SailBoatModel)[], value: CatamaranModel|SailBoatModel) => [...acc, value]),
);
constructor() {
this.addedBoat$.subscribe(data => console.log('DATA', data));
this.boatList$.subscribe(data => console.log('DATA AFTER ADD', data));
}
addBoat(boat: CatamaranModel | SailBoatModel){
this.addedBoatSubject.next(boat);
}
}
在这段代码中,this.boatlist $ .subscribe给我数组中的5个对象,这很好。
addBoat这样调用:
onSubmit(){
if (this.addBoatForm.valid){
this.boatListService.addBoat(
new CatamaranModel(150, 150, 564, 15, false)
);
this.router.navigate(['/']);
console.log('BATEAU AJOUTE');
}
}
但是在此代码中:
constructor(
private boatListService: BoatListService
) {
}
ngOnInit(): void {
this.boatListService.boatList$.subscribe((data) => console.log('IN THE ADD COMPONENT', data));
}
订阅在必要时启动,但总是向我发送旧值(用于初始化的值)。
我不明白为什么我有两个可观察的数据。
如果有人有主意...
这是boatListInitSubject
的预期行为,因为它是BehaviorSubject
主题的一种变体是BehaviorSubject,它具有一个“当前值”的概念。它存储发射到的最新值它的消费者,只要有新的观察者订阅,它就会立即从BehaviorSubject接收“当前值”。
我终于解决了我的问题,
添加后,我重定向到LazyLoading中的另一个页面。
我在此页面的模块中遇到问题(不知道确切的原因,因为我删除并重新创建了模块文件),每次加载此页面时都会重新启动我的可观察服务。