Added getOLiveActivity method

README.md

@@ -27,7 +27,7 @@ allprojects {
 And add next dependencies in the build.gradle of the module:
 ```gradle
 dependencies {
-    compile "com.github.VictorAlbertos:RxActivityResult:0.2.1"
+    compile "com.github.VictorAlbertos:RxActivityResult:0.2.2"
     compile "io.reactivex:rxjava:1.1.0"
 }
 ```

rx_activity_result/src/main/java/rx_activity_result/ActivitiesLifecycleCallbacks.java

@@ -4,6 +4,11 @@
 import android.app.Application;
 import android.os.Bundle;
 
+import java.util.concurrent.TimeUnit;
+
+import rx.Observable;
+import rx.functions.Func1;
+
 class ActivitiesLifecycleCallbacks {
     private final Application application;
     private Activity liveActivityOrNull;
@@ -45,4 +50,33 @@ private void registerActivityLifeCycle() {
     Activity getLiveActivity() {
         return liveActivityOrNull;
     }
+
+    /**
+     * Emits just one time a valid reference to the current activity
+     * @return the current activity
+     */
+    private boolean emitted = false;
+    Observable<Activity> getOLiveActivity() {
+        emitted = false;
+        return Observable.interval(50, 50, TimeUnit.MILLISECONDS)
+                .map(new Func1<Long, Activity>() {
+                    @Override public Activity call(Long aLong) {
+                        return liveActivityOrNull;
+                    }
+                })
+                .takeWhile(new Func1<Activity, Boolean>() {
+                    @Override public Boolean call(Activity activity) {
+                        boolean continueEmitting = true;
+                        if (emitted) continueEmitting = false;
+                        if (activity != null) emitted = true;
+                        return continueEmitting;
+                    }
+                })
+                .filter(new Func1<Activity, Boolean>() {
+                    @Override public Boolean call(Activity activity) {
+                        return activity != null;
+                    }
+                });
+    }
+
 }

rx_activity_result/src/main/java/rx_activity_result/RxActivityResult.java

@@ -27,6 +27,7 @@
 
 import rx.Observable;
 import rx.Subscriber;
+import rx.functions.Action1;
 
 public class RxActivityResult {
     private static ActivitiesLifecycleCallbacks activitiesLifecycle;
@@ -67,8 +68,11 @@ public Observable<Result<T>> startIntent(final Intent intent) {
             OnResult onResult = uiTargetActivity ? onResultActivity() : onResultFragment();
             HolderActivity.setRequest(new Request(intent, onResult));
 
-            Activity activity = activitiesLifecycle.getLiveActivity();
-            activity.startActivity(new Intent(activity, HolderActivity.class));
+            activitiesLifecycle.getOLiveActivity().subscribe(new Action1<Activity>() {
+                @Override public void call(Activity activity) {
+                    activity.startActivity(new Intent(activity, HolderActivity.class));
+                }
+            });
 
             return observable;
         }