Merge pull request #40 from lkopocinski/2.x

Forward Throwable to onError() when ActivityNotFoundException thrown

Author: VictorAlbertos

app/src/main/java/app/OnPreResultActivity.java

@@ -26,7 +26,7 @@ protected void onCreate(Bundle savedInstanceState) {
 
         startPreForResult.setOnClickListener(v ->
             RxActivityResult.on(this)
-                .startIntent(new Intent(this, FirstActivity.class), (resultCode, data) ->
+                .startIntent(new Intent(this, FirstActivity.class), (resultCode, requestCode, data) ->
                         Observable.just(Ignore.Get)
                                 .map(_I -> data.putExtra(EXTRA_PRE, "Do whatever you want with the data, but not with the UI")))
                 .subscribe(result -> {

app/src/main/java/app/SampleActivity.java

@@ -34,7 +34,7 @@ private void camera() {
                     } else {
                         result.targetUI().printUserCanceled();
                     }
-                });
+                }, Throwable::printStackTrace);
     }
 
     private void showImage(Intent data) {

rx_activity_result/src/main/java/rx_activity_result2/HolderActivity.java

@@ -17,6 +17,7 @@
 package rx_activity_result2;
 
 import android.app.Activity;
+import android.content.ActivityNotFoundException;
 import android.content.Intent;
 import android.content.IntentSender;
 import android.os.Bundle;
@@ -52,7 +53,13 @@ protected void onCreate(Bundle savedInstanceState) {
             if (requestIntentSender.getOptions() == null) startIntentSender(requestIntentSender);
             else startIntentSenderWithOptions(requestIntentSender);
         } else {
-            startActivityForResult(request.intent(), 0);
+            try {
+                startActivityForResult(request.intent(), 0);
+            } catch (ActivityNotFoundException e) {
+                if (onResult != null) {
+                    onResult.error(e);
+                }
+            }
         }
     }
 

rx_activity_result/src/main/java/rx_activity_result2/OnResult.java

@@ -7,4 +7,5 @@
 
 interface OnResult extends Serializable {
     void response(int requestCode, int resultCode, @Nullable Intent data);
+    void error(Throwable throwable);
 }

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

@@ -117,6 +117,11 @@ public void response(int requestCode, int resultCode, Intent data) {
                     subject.onNext(new Result<>(activity, requestCode, resultCode, data));
                     subject.onComplete();
                 }
+
+                @Override
+                public void error(Throwable throwable) {
+                    subject.onError(throwable);
+                }
             };
         }
 
@@ -141,6 +146,11 @@ public void response(int requestCode, int resultCode, Intent data) {
                     //If code reaches this point it means some other activity has been stacked as a secondary process.
                     //Do nothing until the current activity be the target activity to get the associated fragment
                 }
+
+                @Override
+                public void error(Throwable throwable) {
+                    subject.onError(throwable);
+                }
             };
         }