blob: 61243c345a6da463da7e9584511929a6fd06ce15 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
|
package cgeo.geocaching.sensors;
import cgeo.geocaching.sensors.GpsStatusProvider.Status;
import cgeo.geocaching.utils.Log;
import cgeo.geocaching.utils.RxUtils.ConnectableLooperCallbacks;
import rx.Observable;
import rx.Observable.OnSubscribe;
import rx.Subscriber;
import rx.observables.ConnectableObservable;
import rx.subjects.BehaviorSubject;
import android.content.Context;
import android.location.GpsSatellite;
import android.location.GpsStatus;
import android.location.LocationManager;
public class GpsStatusProvider implements OnSubscribe<Status> {
public static class Status {
final public boolean gpsEnabled;
final public int satellitesVisible;
final public int satellitesFixed;
public Status(final boolean gpsEnabled, final int satellitesVisible, final int satellitesFixed) {
this.gpsEnabled = gpsEnabled;
this.satellitesVisible = satellitesVisible;
this.satellitesFixed = satellitesFixed;
}
}
private final LocationManager geoManager;
private final BehaviorSubject<Status> subject;
private Status latest = new Status(false, 0, 0);
/**
* Build a new gps status provider object.
* <p/>
* There is no need to instantiate more than one such object in an application, as observers can be added
* at will.
*
* @param context the context used to retrieve the system services
*/
protected GpsStatusProvider(final Context context) {
geoManager = (LocationManager) context.getSystemService(Context.LOCATION_SERVICE);
subject = BehaviorSubject.create(latest);
}
public static Observable<Status> create(final Context context) {
final GpsStatusProvider provider = new GpsStatusProvider(context);
return provider.worker.refCount();
}
@Override
public void call(final Subscriber<? super Status> subscriber) {
subject.subscribe(subscriber);
}
final ConnectableObservable<Status> worker = new ConnectableLooperCallbacks<Status>(this) {
private final GpsStatus.Listener gpsStatusListener = new GpsStatusListener();
@Override
protected void onStart() {
Log.d("GpsStatusProvider: starting the GPS status listener");
geoManager.addGpsStatusListener(gpsStatusListener);
}
@Override
protected void onStop() {
Log.d("GpsStatusProvider: stopping the GPS status listener");
geoManager.removeGpsStatusListener(gpsStatusListener);
}
};
private final class GpsStatusListener implements GpsStatus.Listener {
@Override
public void onGpsStatusChanged(final int event) {
switch (event) {
case GpsStatus.GPS_EVENT_FIRST_FIX:
case GpsStatus.GPS_EVENT_SATELLITE_STATUS: {
final GpsStatus status = geoManager.getGpsStatus(null);
int visible = 0;
int fixed = 0;
for (final GpsSatellite satellite : status.getSatellites()) {
if (satellite.usedInFix()) {
fixed++;
}
visible++;
}
if (visible == latest.satellitesVisible && fixed == latest.satellitesFixed) {
return;
}
latest = new Status(true, visible, fixed);
break;
}
case GpsStatus.GPS_EVENT_STARTED:
latest = new Status(true, 0, 0);
break;
case GpsStatus.GPS_EVENT_STOPPED:
latest = new Status(false, 0, 0);
break;
default:
throw new IllegalStateException();
}
subject.onNext(latest);
}
}
}
|
