Обновлены локальные переменные при каждом изменении данных в облачном хранилище

Question

У меня проблема с настройкой локальных переменных каждый раз, когда данные в облачном хранилище.Например, в вызове локальной переменной count_vehicle значение представляет собой счетчик значений со специальным условием на основе данных в облачном хранилище.Для примеров после запуска программы count_vehicle = 4, когда я изменяю данные в firestore, переменные count_vehicle должны 3 после некоторого вычисления, но вместо count_vehicle become 7 (3+4).Чтобы решить эту проблему, я намерен установить count vehicle = 0 перед началом расчета.Это мой код

dashboard.component.ts

//import section

//component declaration section



export class DashboardComponent implements OnInit {
  items = any[];
  count_vehicle: number =0;

  constructor(public service: FireService) {
  }
  startAnimationForLineChart(chart){
  ngOnInit() {
      this.service.getVehicle().pipe(     
        map(actions => actions.map(a => {       
          const data = a.payload.doc.data();
          const id = a.payload.doc.id;
          if(data.value>300){
            this.count_vehicle++;
          }
          return {id, .. data};
        }))
      ) 
      .subscribe(res => {
        this.items = res;       
        console.log(res)
      })

      }
}

fire.service.ts

import { Injectable } from '@angular/core';
import { AngularFirestore } from '@angular/fire/firestore';
import { Observable } from 'rxjs';

@Injectable({
  providedIn: 'root'
})
export class FireService {

  constructor(public db : AngularFirestore) { }

  getVehicle() : Observable<any[]>{
    return this.db.collection('/recent_sensor_data').snapshotChanges()
    }
    }
  }

Спасибо, если вы можете помочь. Извините за мой английский

Answer 1

Вы должны иметь возможность добавить значение для сброса счетчика в наблюдаемое что-то вроде:

this.service.getVehicle().merge(Rx.Observable.from([ -1*this.count_vehicle ])).pipe(...