Почему не меняется поток rxjs?

Имеется:

public events$: BehaviorSubject<IEvent[]> = new BehaviorSubject<IEvent[]>([]);


Данные запрашиваются и пробрасываются в events$:

this.load().subscribe((response) => {
      this.events$.next(response);
    });


Есть функция, которая меняет данные в потоке:

public checkAll() {
    this.events$.pipe(
      map((events: IEvent[]) => {
        return events.map((event: IEvent) => {
          event.checked_export = !event.checked_export;
          return event;
        });
      })
    );
  }


Почему, если подписаться на events$, ничего не меняется после вызова функции checkAll()

Как мне кажется нужно сделать this.events$ = this.events$.pipe()... либо пробросить замэппеный объект: this.events$.next(mapped)
  • Вопрос задан
  • 55 просмотров
Пригласить эксперта
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы
от 100 000 до 200 000 ₽
Orderz.pro Москва
от 100 000 до 200 000 ₽
Applicatura Санкт-Петербург
от 150 000 до 200 000 ₽
25 янв. 2021, в 13:34
3000 руб./за проект
25 янв. 2021, в 13:09
3001 руб./за проект
25 янв. 2021, в 13:08
2000 руб./за проект