Remove exceptions from signatures

Author: ZacSweers

src/main/java/io/reactivex/Completable.java

@@ -927,12 +927,7 @@ public final Completable andThen(CompletableSource next) {
     @CheckReturnValue
     @SchedulerSupport(SchedulerSupport.NONE)
     public final <R> R as(@NonNull CompletableConverter<? extends R> converter) {
-        try {
-            return ObjectHelper.requireNonNull(converter, "converter is null").apply(this);
-        } catch (Throwable ex) {
-            Exceptions.throwIfFatal(ex);
-            throw ExceptionHelper.wrapOrThrow(ex);
-        }
+        return ObjectHelper.requireNonNull(converter, "converter is null").apply(this);
     }
 
     /**

src/main/java/io/reactivex/CompletableConverter.java

@@ -29,8 +29,7 @@ public interface CompletableConverter<R> {
      *
      * @param upstream the upstream Completable instance
      * @return the converted value
-     * @throws Exception on error
      */
     @NonNull
-    R apply(@NonNull Completable upstream) throws Exception;
+    R apply(@NonNull Completable upstream);
 }

src/main/java/io/reactivex/Flowable.java

@@ -5259,12 +5259,7 @@ public final Single<Boolean> any(Predicate<? super T> predicate) {
     @BackpressureSupport(BackpressureKind.SPECIAL)
     @SchedulerSupport(SchedulerSupport.NONE)
     public final <R> R as(@NonNull FlowableConverter<T, ? extends R> converter) {
-        try {
-            return ObjectHelper.requireNonNull(converter, "converter is null").apply(this);
-        } catch (Throwable ex) {
-            Exceptions.throwIfFatal(ex);
-            throw ExceptionHelper.wrapOrThrow(ex);
-        }
+        return ObjectHelper.requireNonNull(converter, "converter is null").apply(this);
     }
 
     /**

src/main/java/io/reactivex/FlowableConverter.java

@@ -30,8 +30,7 @@ public interface FlowableConverter<T, R> {
      *
      * @param upstream the upstream Flowable instance
      * @return the converted value
-     * @throws Exception on error
      */
     @NonNull
-    R apply(@NonNull Flowable<T> upstream) throws Exception;
+    R apply(@NonNull Flowable<T> upstream);
 }

src/main/java/io/reactivex/Maybe.java

@@ -2008,12 +2008,7 @@ public final Maybe<T> ambWith(MaybeSource<? extends T> other) {
     @CheckReturnValue
     @SchedulerSupport(SchedulerSupport.NONE)
     public final <R> R as(@NonNull MaybeConverter<T, ? extends R> converter) {
-        try {
-            return ObjectHelper.requireNonNull(converter, "converter is null").apply(this);
-        } catch (Throwable ex) {
-            Exceptions.throwIfFatal(ex);
-            throw ExceptionHelper.wrapOrThrow(ex);
-        }
+        return ObjectHelper.requireNonNull(converter, "converter is null").apply(this);
     }
 
     /**

src/main/java/io/reactivex/MaybeConverter.java

@@ -30,8 +30,7 @@ public interface MaybeConverter<T, R> {
      *
      * @param upstream the upstream Maybe instance
      * @return the converted value
-     * @throws Exception on error
      */
     @NonNull
-    R apply(@NonNull Maybe<T> upstream) throws Exception;
+    R apply(@NonNull Maybe<T> upstream);
 }

src/main/java/io/reactivex/Observable.java

@@ -4819,12 +4819,7 @@ public final Single<Boolean> any(Predicate<? super T> predicate) {
     @CheckReturnValue
     @SchedulerSupport(SchedulerSupport.NONE)
     public final <R> R as(@NonNull ObservableConverter<T, ? extends R> converter) {
-        try {
-            return ObjectHelper.requireNonNull(converter, "converter is null").apply(this);
-        } catch (Throwable ex) {
-            Exceptions.throwIfFatal(ex);
-            throw ExceptionHelper.wrapOrThrow(ex);
-        }
+        return ObjectHelper.requireNonNull(converter, "converter is null").apply(this);
     }
 
     /**

src/main/java/io/reactivex/ObservableConverter.java

@@ -30,8 +30,7 @@ public interface ObservableConverter<T, R> {
      *
      * @param upstream the upstream Observable instance
      * @return the converted value
-     * @throws Exception on error
      */
     @NonNull
-    R apply(@NonNull Observable<T> upstream) throws Exception;
+    R apply(@NonNull Observable<T> upstream);
 }

src/main/java/io/reactivex/Single.java

@@ -1541,12 +1541,7 @@ public final Single<T> ambWith(SingleSource<? extends T> other) {
     @CheckReturnValue
     @SchedulerSupport(SchedulerSupport.NONE)
     public final <R> R as(@NonNull SingleConverter<T, ? extends R> converter) {
-        try {
-            return ObjectHelper.requireNonNull(converter, "converter is null").apply(this);
-        } catch (Throwable ex) {
-            Exceptions.throwIfFatal(ex);
-            throw ExceptionHelper.wrapOrThrow(ex);
-        }
+        return ObjectHelper.requireNonNull(converter, "converter is null").apply(this);
     }
 
     /**

src/main/java/io/reactivex/SingleConverter.java

@@ -30,8 +30,7 @@ public interface SingleConverter<T, R> {
      *
      * @param upstream the upstream Single instance
      * @return the converted value
-     * @throws Exception on error
      */
     @NonNull
-    R apply(@NonNull Single<T> upstream) throws Exception;
+    R apply(@NonNull Single<T> upstream);
 }

src/main/java/io/reactivex/parallel/ParallelFlowable.java

@@ -137,12 +137,7 @@ public static <T> ParallelFlowable<T> from(@NonNull Publisher<? extends T> sourc
     @CheckReturnValue
     @NonNull
     public final <R> R as(@NonNull ParallelFlowableConverter<T, R> converter) {
-        try {
-            return ObjectHelper.requireNonNull(converter, "converter is null").apply(this);
-        } catch (Throwable ex) {
-            Exceptions.throwIfFatal(ex);
-            throw ExceptionHelper.wrapOrThrow(ex);
-        }
+        return ObjectHelper.requireNonNull(converter, "converter is null").apply(this);
     }
 
     /**

src/main/java/io/reactivex/parallel/ParallelFlowableConverter.java

@@ -30,8 +30,7 @@ public interface ParallelFlowableConverter<T, R> {
      *
      * @param upstream the upstream ParallelFlowable instance
      * @return the converted value
-     * @throws Exception on error
      */
     @NonNull
-    R apply(@NonNull ParallelFlowable<T> upstream) throws Exception;
+    R apply(@NonNull ParallelFlowable<T> upstream);
 }