Converted observer to behaviorsubject

This commit is contained in:
Willem Dantuma 2020-05-19 11:46:27 +02:00
parent 51bb5b3833
commit 4a0474546c

View File

@ -1,5 +1,5 @@
import { Injectable } from '@angular/core'; import { Injectable } from '@angular/core';
import { Observer, Observable } from 'rxjs'; import { Observer, Observable,BehaviorSubject } from 'rxjs';
/** /**
* GeolocationService class. * GeolocationService class.
@ -9,23 +9,15 @@ import { Observer, Observable } from 'rxjs';
@Injectable() @Injectable()
export class GeolocationService { export class GeolocationService {
/** private positionObserver$:BehaviorSubject<Position> = new BehaviorSubject<Position>(null);
* Tries HTML5 geolocation.
* constructor() {
* Wraps the Geolocation API into an observable.
*
* @return An observable of Position
*/
getCurrentPosition(): Observable<Position> {
return Observable.create((observer: Observer<Position>) => {
// Invokes getCurrentPosition method of Geolocation API.
navigator.geolocation.watchPosition( navigator.geolocation.watchPosition(
(position: Position) => { (position: Position) => {
observer.next(position); this.positionObserver$.next(position);
}, },
(error: PositionError) => { (error: PositionError) => {
console.debug('Geolocation service: ' + error.message); console.debug('Geolocation service: ' + error.message);
//observer.error(error);
}, },
{ {
enableHighAccuracy: true, enableHighAccuracy: true,
@ -33,7 +25,10 @@ export class GeolocationService {
maximumAge: 0 maximumAge: 0
} }
); );
});
} }
getCurrentPosition(): Observable<Position> {
return this.positionObserver$;
}
} }