import { Injectable } from '@angular/core';
import { HttpClient, HttpHeaders } from '@angular/common/http';
import { Observable, of, EMPTY } from 'rxjs';
-import { catchError, tap } from 'rxjs/operators';
+import { catchError, map, tap } from 'rxjs/operators';
+import { select, Store } from '@ngrx/store';
import { Vorgang } from './vorgang';
+import { State } from './reducers/vorgang';
@Injectable({
})
};
- constructor(private http: HttpClient) { }
+ constructor(
+ private http: HttpClient,
+ private store: Store<{ vorgang: State }>) { }
/** POST: Einen neuen Vorgang erzeugen */
create(vorgang: Vorgang): Observable<Vorgang> {
return this.gpsUrl + vbId + '/save';
}
+ Observable<number> observe() {
+ return this.store.pipe(select('vorgang'), map(vorgang => vorgang.counter));
+ }
+
/**
* Handle Http operation that failed.
* Let the app continue.