rxjs 相关问题

我有这项服务： @Injectable({ 提供于： 'root', }) 导出类BackgroundLayersService { 私人mapSubject =新BehaviorSubject(null); 地图$：可观察我有这项服务： @Injectable({ providedIn: 'root', }) export class BackgroundLayersService { private mapSubject = new BehaviorSubject<Map | null>(null); map$: Observable<Map | null> = this.mapSubject.asObservable(); constructor(private mapService: MapService) { this.mapService.map$.subscribe((map: Map | null) => { console.log('Map updated in BackgroundLayersService:', map); this.mapSubject.next(map); }); } public map: Map | null; changeLayer(input: any) { console.log('test'); console.log(this.map); } } 它从另一个服务加载“地图”，这是另一个服务： @Injectable({ providedIn: 'root', }) export class MapService { constructor(private store: Store) { } @ViewChild('mapId') mapContainer: ElementRef; private mapSubject = new BehaviorSubject<Map | null>(null); map$ = this.mapSubject.asObservable(); initializeMap(): void { this.setMap( L.map('mapId', { layers: [], }).setView([1, 1], 6) ); } } 调用 setMap 时，第一个服务的构造函数控制台会记录正确的值。然而，当调用changeLayer时，控制台日志显示map的值为null。我不明白这是为什么，而且我似乎无法将此映射值传递给其他组件或服务。将不胜感激任何帮助。相关信息：在调用changeLayer之前，this.map已更新为正确的值。 initializeMap 设置地图： initializeMap(): void { this.setMap( L.map('mapId', {} ); } 发生在这里： init = () => { this.mapService.initializeMap(); this.mapService.map$.subscribe((map) => { this.mapInstance = map; }); } 这里来自 subscribe 的 map 值也是正确的，稍后在组件中使用了 map 值并且不为 null。这里运行无限循环，当您订阅行为主题时，订阅代码将被触发，如果您不希望它在第一次加载时触发，您可以使用主题，在其中调用 next 方法订阅，这会再次调用subscribe，然后next等等，请先摆脱无限循环！所以无论设置什么值，我猜都会被无限循环删除！另一种选择可以如下所示！ @Injectable({ providedIn: 'root', }) export class BackgroundLayersService { private mapSubject = new BehaviorSubject<Map | null>(null); map$: Observable<Map | null> = this.mapSubject.asObservable(); constructor(private mapService: MapService) { this.mapService.map$.subscribe((map: Map | null) => { // <-- infinite loop console.log('Map updated in BackgroundLayersService:', map); if(map) { // this if condition gets rid of the infinite loop! this.mapSubject.next(map); // <-- infinite loop } }); } public map: Map | null; changeLayer(input: any) { console.log('test'); console.log(this.map); } }

angular rxjs

回答 1 投票 0

我应该在 RxJ 和 Angular 中为主题使用“$”符号后缀吗？

所以我有一个关于 RxJs 代码和 Angular 中 $ 符号后缀命名约定的问题。在角度最佳实践文档和总体中，我发现我们应该使用 i...

angular rxjs observable subject

回答 4 投票 0

是否自动处理 Angular/RxJS Observables 的取消订阅

我听说 Angular 会自动处理它自己的 Observables 的取消订阅，因此不需要手动取消订阅 observables。我留下的印象是...

angular rxjs rxjs-observables

回答 1 投票 0

Reactivo 编程练习

我有一个可观察的源，当您单击时会发出。我想制作一个像下一个弹珠图一样发出的运算符...... 也就是说，它在第一次单击时发出。然后，当你...