Angular-多个订阅无法获得相同的答案

问题描述 投票:0回答:2

我有一个小问题,我订阅了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));
  }

订阅在必要时启动,但总是向我发送旧值(用于初始化的值)。

我不明白为什么我有两个可观察的数据。

如果有人有主意...

angular observable rxjs6
2个回答
0
投票

这是boatListInitSubject的预期行为,因为它是BehaviorSubject

主题的一种变体是BehaviorSubject,它具有一个“当前值”的概念。它存储发射到的最新值它的消费者,只要有新的观察者订阅,它就会立即从BehaviorSubject接收“当前值”。


0
投票

我终于解决了我的问题,

添加后,我重定向到LazyLoading中的另一个页面。

我在此页面的模块中遇到问题(不知道确切的原因,因为我删除并重新创建了模块文件),每次加载此页面时都会重新启动我的可观察服务。

© www.soinside.com 2019 - 2024. All rights reserved.