RxLocationManager CreateLocationObservable

CreateLocationObservable

private fun createLocationObservable(attributes: RxLocationAttributes): Observable<Location> {
    return Observable.create { emitter ->
        val listener = getLocationListener(emitter)
        val completeListener = getOnCompleteListener(emitter)
        try {
            fusedLocationProviderClient.lastLocation.addOnSuccessListener {
                if (!emitter.isDisposed && it != null) emitter.onNext(it)
            }
            val task = fusedLocationProviderClient.requestLocationUpdates(
                getLocationRequest(attributes),
                listener,
                if (attributes.useCalledThreadToEmitValue) null else Looper.getMainLooper()
            )
            task.addOnCompleteListener(completeListener)
        } catch (e: Exception) {
            emitter.tryOnError(e)
        }
        emitter.setCancellable(getCancellable(listener))
    }
}