typelogic · November 15, 2021 14:20 · Oct 28, 2015 · Oct 28, 2015 · Oct 28, 2015
diff --git a/...reateObservableFromDeviceEventEmitter$.js → 01-createObservableFromDeviceEventEmitter.js b/...reateObservableFromDeviceEventEmitter$.js → 01-createObservableFromDeviceEventEmitter.js
diff --git a/createObservableFromDeviceEventEmitter$.js → ...reateObservableFromDeviceEventEmitter$.js b/createObservableFromDeviceEventEmitter$.js → ...reateObservableFromDeviceEventEmitter$.js
diff --git a/locationDidUpdate.js → 02-locationDidUpdate.js b/locationDidUpdate.js → 02-locationDidUpdate.js
diff --git a/locationCheckExample.js → 03-locationCheckExample.js b/locationCheckExample.js → 03-locationCheckExample.js
diff --git a/createObservableFromDeviceEventEmitter$.js b/createObservableFromDeviceEventEmitter$.js
@@ -0,0 +1,14 @@
+import React, {DeviceEventEmitter} from 'react-native';
+import {Observable} from 'rx-lite'
+
+/**
+ * Creates an Observable to listen to any event of DeviceEventEmitter
+ * @param type {string} Event type
+ */
+export default createObservableFromDeviceEventEmitter$ = type => {
+  let subscription;
+  return Observable.fromEventPattern(
+    handler => subscription = DeviceEventEmitter.addListener(type, handler),
+    handler => subscription.remove()
+  )
+}
diff --git a/locationCheckExample.js b/locationCheckExample.js
@@ -0,0 +1,20 @@
+import Location from 'react-native-location';
+import locationDidUpdate$ from './locationDidUpdate';
+
+// init native location 
+Location.requestAlwaysAuthorization();
+Location.startUpdatingLocation();
+
+// subscribe to changes
+const subscription = locationDidUpdate$(2000/* delay ms */)
+  .subscribe(
+    (location) => {
+      // do anything with the location
+      console.log('location updated', location)
+    },
+    (e) => console.log('onError: %s', e);
+  );
+
+// to unsubscribe just call 
+// subscription.dispose();
+
diff --git a/locationDidUpdate.js b/locationDidUpdate.js
@@ -0,0 +1,18 @@
+import createObservableFromDeviceEventEmitter$ from './createObservableFromDeviceEventEmitter';
+
+/**
+ * Creates an Observable to listen to `locationUpdated` event
+ * dispatched by Location (react-native-location)
+ */
+export default locationDidUpdate$ = (delay=1000) => {
+
+  return createObservableFromDeviceEventEmitter$('locationUpdated')
+      .throttle(delay) // delay of listening to events
+      .map((location) => {
+        // map latitude + longitude into simple object
+        return {
+          latitude: location.coords.latitude,
+          longitude: location.coords.longitude
+        }
+      });
+}