Skip to content

Commit

Permalink
3.x: widen throws on the XOnSubscribe interfaces (#6579)
Browse files Browse the repository at this point in the history
  • Loading branch information
akarnokd authored Jul 19, 2019
1 parent d9c0760 commit 028d33e
Show file tree
Hide file tree
Showing 5 changed files with 10 additions and 10 deletions.
4 changes: 2 additions & 2 deletions src/main/java/io/reactivex/CompletableOnSubscribe.java
Original file line number Diff line number Diff line change
Expand Up @@ -24,8 +24,8 @@ public interface CompletableOnSubscribe {
/**
* Called for each CompletableObserver that subscribes.
* @param emitter the safe emitter instance, never null
* @throws Exception on error
* @throws Throwable on error
*/
void subscribe(@NonNull CompletableEmitter emitter) throws Exception;
void subscribe(@NonNull CompletableEmitter emitter) throws Throwable;
}

4 changes: 2 additions & 2 deletions src/main/java/io/reactivex/FlowableOnSubscribe.java
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,8 @@ public interface FlowableOnSubscribe<T> {
/**
* Called for each Subscriber that subscribes.
* @param emitter the safe emitter instance, never null
* @throws Exception on error
* @throws Throwable on error
*/
void subscribe(@NonNull FlowableEmitter<T> emitter) throws Exception;
void subscribe(@NonNull FlowableEmitter<T> emitter) throws Throwable;
}

4 changes: 2 additions & 2 deletions src/main/java/io/reactivex/MaybeOnSubscribe.java
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,8 @@ public interface MaybeOnSubscribe<T> {
/**
* Called for each MaybeObserver that subscribes.
* @param emitter the safe emitter instance, never null
* @throws Exception on error
* @throws Throwable on error
*/
void subscribe(@NonNull MaybeEmitter<T> emitter) throws Exception;
void subscribe(@NonNull MaybeEmitter<T> emitter) throws Throwable;
}

4 changes: 2 additions & 2 deletions src/main/java/io/reactivex/ObservableOnSubscribe.java
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,8 @@ public interface ObservableOnSubscribe<T> {
/**
* Called for each Observer that subscribes.
* @param emitter the safe emitter instance, never null
* @throws Exception on error
* @throws Throwable on error
*/
void subscribe(@NonNull ObservableEmitter<T> emitter) throws Exception;
void subscribe(@NonNull ObservableEmitter<T> emitter) throws Throwable;
}

4 changes: 2 additions & 2 deletions src/main/java/io/reactivex/SingleOnSubscribe.java
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,8 @@ public interface SingleOnSubscribe<T> {
/**
* Called for each SingleObserver that subscribes.
* @param emitter the safe emitter instance, never null
* @throws Exception on error
* @throws Throwable on error
*/
void subscribe(@NonNull SingleEmitter<T> emitter) throws Exception;
void subscribe(@NonNull SingleEmitter<T> emitter) throws Throwable;
}

0 comments on commit 028d33e

Please sign in to comment.