- * Default: null - * - * @param customCallbackHandler handler instance - * @return builder instance - */ - public Builder setCustomCallbackHandler(@Nullable Handler customCallbackHandler) { - this.customCallbackHandler = customCallbackHandler; - return this; - } - - /** - * Property that allows automatic retries of connection to Google Play Services when it has bean suspended. - *
- * Default: false
- *
- * @param retryOnConnectionSuspended if should we retry on connection failure
- * @return builder instance
- */
- public Builder setRetryOnConnectionSuspended(boolean retryOnConnectionSuspended) {
- this.retryOnConnectionSuspended = retryOnConnectionSuspended;
- return this;
- }
-
- /**
- * Builds configuration instance
- *
- * @return configuration instance
- */
- public ReactiveLocationProviderConfiguration build() {
- return new ReactiveLocationProviderConfiguration(this);
- }
- }
-}
diff --git a/android-reactive-location/src/main/java/pl/charmas/android/reactivelocation2/ReactiveLocationProviderConfiguration.kt b/android-reactive-location/src/main/java/pl/charmas/android/reactivelocation2/ReactiveLocationProviderConfiguration.kt
new file mode 100644
index 00000000..0af88f26
--- /dev/null
+++ b/android-reactive-location/src/main/java/pl/charmas/android/reactivelocation2/ReactiveLocationProviderConfiguration.kt
@@ -0,0 +1,67 @@
+package pl.charmas.android.reactivelocation2
+
+import android.os.Handler
+
+/**
+ * Configuration for location provider. Pleas use builder to create an instance.
+ */
+class ReactiveLocationProviderConfiguration private constructor(builder: Builder) {
+
+ val customCallbackHandler: Handler? = builder.customCallbackHandler
+ val isRetryOnConnectionSuspended: Boolean = builder.retryOnConnectionSuspended
+
+ class Builder {
+ var customCallbackHandler: Handler? = null
+ private set(value) {
+ field = value
+ }
+ var retryOnConnectionSuspended = false
+ private set(value) {
+ field = value
+ }
+
+ /**
+ * Allows to set custom handler on which all Google Play Services callbacks are called.
+ *
+ *
+ * Default: null
+ *
+ * @param customCallbackHandler handler instance
+ * @return builder instance
+ */
+ fun setCustomCallbackHandler(customCallbackHandler: Handler?): Builder {
+ this.customCallbackHandler = customCallbackHandler
+ return this
+ }
+
+ /**
+ * Property that allows automatic retries of connection to Google Play Services when it has bean suspended.
+ *
+ *
+ * Default: false
+ *
+ * @param retryOnConnectionSuspended if should we retry on connection failure
+ * @return builder instance
+ */
+ fun setRetryOnConnectionSuspended(retryOnConnectionSuspended: Boolean): Builder {
+ this.retryOnConnectionSuspended = retryOnConnectionSuspended
+ return this
+ }
+
+ /**
+ * Builds configuration instance
+ *
+ * @return configuration instance
+ */
+ fun build(): ReactiveLocationProviderConfiguration {
+ return ReactiveLocationProviderConfiguration(this)
+ }
+ }
+
+ companion object {
+ @JvmStatic
+ fun builder(): Builder {
+ return Builder()
+ }
+ }
+}
\ No newline at end of file
diff --git a/android-reactive-location/src/main/java/pl/charmas/android/reactivelocation2/ReactivePlacesProvider.kt b/android-reactive-location/src/main/java/pl/charmas/android/reactivelocation2/ReactivePlacesProvider.kt
new file mode 100644
index 00000000..8bcdadc0
--- /dev/null
+++ b/android-reactive-location/src/main/java/pl/charmas/android/reactivelocation2/ReactivePlacesProvider.kt
@@ -0,0 +1,173 @@
+package pl.charmas.android.reactivelocation2
+
+import android.content.Context
+import android.graphics.Bitmap
+import androidx.annotation.IntRange
+import androidx.annotation.RequiresPermission
+import com.google.android.libraries.places.api.Places
+import com.google.android.libraries.places.api.model.AutocompletePrediction
+import com.google.android.libraries.places.api.model.PhotoMetadata
+import com.google.android.libraries.places.api.model.Place
+import com.google.android.libraries.places.api.net.FetchPhotoRequest
+import com.google.android.libraries.places.api.net.FetchPlaceRequest
+import com.google.android.libraries.places.api.net.FetchPlaceResponse
+import com.google.android.libraries.places.api.net.FindAutocompletePredictionsRequest
+import com.google.android.libraries.places.api.net.FindAutocompletePredictionsResponse
+import com.google.android.libraries.places.api.net.FindCurrentPlaceRequest
+import com.google.android.libraries.places.api.net.FindCurrentPlaceResponse
+import io.reactivex.Maybe
+import io.reactivex.Observable
+import pl.charmas.android.reactivelocation2.ext.errorSkip
+import pl.charmas.android.reactivelocation2.ext.mapOrEmpty
+import pl.charmas.android.reactivelocation2.ext.toMaybe
+import java.util.Collections
+
+class ReactivePlacesProvider constructor(
+ val context: Context,
+) {
+
+ private val placesClient = Places.createClient(context)
+
+ /**
+ * Returns observable that fetches current place from Places API. To flatmap and auto release
+ * buffer to {@link com.google.android.gms.location.places.PlaceLikelihood} observable use
+ * {@link DataBufferObservable}.
+ *
+ * @param placeFilter filter
+ * @return observable that emits current places buffer and completes
+ */
+ @RequiresPermission(allOf = ["android.permission.ACCESS_FINE_LOCATION", "android.permission.ACCESS_WIFI_STATE"])
+ fun getCurrentPlace(placeFilter: FindCurrentPlaceRequest): Maybe