RxLocationManager.java 文件源码

@SuppressWarnings("MissingPermission")
@RequiresPermission(anyOf = {
        Manifest.permission.ACCESS_COARSE_LOCATION,
        Manifest.permission.ACCESS_FINE_LOCATION
})
private Observable<Location> locationUpdates() {
    return rxLocation.location().updates(locationRequest)
            .subscribeOn(Schedulers.io())
            .doOnSubscribe(ignore -> Timber.d("locationUpdates: on subscribe"))
            .doOnNext(item -> Timber.d("locationUpdates: item: " + item))
            .doOnComplete(() -> Timber.d("locationUpdates: on complete"))
            .doOnDispose(() -> Timber.d("locationUpdates: on dispose"));
}