Skip to content

Commit 028d33e

Browse files
authored
3.x: widen throws on the XOnSubscribe interfaces (ReactiveX#6579)
1 parent d9c0760 commit 028d33e

File tree

5 files changed

+10
-10
lines changed

5 files changed

+10
-10
lines changed

src/main/java/io/reactivex/CompletableOnSubscribe.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -24,8 +24,8 @@ public interface CompletableOnSubscribe {
2424
/**
2525
* Called for each CompletableObserver that subscribes.
2626
* @param emitter the safe emitter instance, never null
27-
* @throws Exception on error
27+
* @throws Throwable on error
2828
*/
29-
void subscribe(@NonNull CompletableEmitter emitter) throws Exception;
29+
void subscribe(@NonNull CompletableEmitter emitter) throws Throwable;
3030
}
3131

src/main/java/io/reactivex/FlowableOnSubscribe.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,8 @@ public interface FlowableOnSubscribe<T> {
2626
/**
2727
* Called for each Subscriber that subscribes.
2828
* @param emitter the safe emitter instance, never null
29-
* @throws Exception on error
29+
* @throws Throwable on error
3030
*/
31-
void subscribe(@NonNull FlowableEmitter<T> emitter) throws Exception;
31+
void subscribe(@NonNull FlowableEmitter<T> emitter) throws Throwable;
3232
}
3333

src/main/java/io/reactivex/MaybeOnSubscribe.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,8 @@ public interface MaybeOnSubscribe<T> {
2626
/**
2727
* Called for each MaybeObserver that subscribes.
2828
* @param emitter the safe emitter instance, never null
29-
* @throws Exception on error
29+
* @throws Throwable on error
3030
*/
31-
void subscribe(@NonNull MaybeEmitter<T> emitter) throws Exception;
31+
void subscribe(@NonNull MaybeEmitter<T> emitter) throws Throwable;
3232
}
3333

src/main/java/io/reactivex/ObservableOnSubscribe.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,8 @@ public interface ObservableOnSubscribe<T> {
2626
/**
2727
* Called for each Observer that subscribes.
2828
* @param emitter the safe emitter instance, never null
29-
* @throws Exception on error
29+
* @throws Throwable on error
3030
*/
31-
void subscribe(@NonNull ObservableEmitter<T> emitter) throws Exception;
31+
void subscribe(@NonNull ObservableEmitter<T> emitter) throws Throwable;
3232
}
3333

src/main/java/io/reactivex/SingleOnSubscribe.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,8 @@ public interface SingleOnSubscribe<T> {
2626
/**
2727
* Called for each SingleObserver that subscribes.
2828
* @param emitter the safe emitter instance, never null
29-
* @throws Exception on error
29+
* @throws Throwable on error
3030
*/
31-
void subscribe(@NonNull SingleEmitter<T> emitter) throws Exception;
31+
void subscribe(@NonNull SingleEmitter<T> emitter) throws Throwable;
3232
}
3333

0 commit comments

Comments
 (0)