alouanemed
08/15/2017, 6:09 PMKotlin :
override fun startLocationRefresh() {
disposable.add(rxLocation.settings()
.checkAndHandleResolution(locationRequest)
.flatMapObservable<Address>(Function<Boolean, ObservableSource<out Address>> { this.getAddressObservable(it) })
.observeOn(AndroidSchedulers.mainThread())
.subscribe(Consumer<Address> { view.onAddressUpdate(it) }
) { throwable ->
Timber.e("Error fetching location/address updates",
throwable.message)
})
}