Skip to content

Commit 3489cc1

Browse files
vanniktechakarnokd
authored andcommitted
2.x: Change Completable to CompletableSource (#4924)
1 parent 1875256 commit 3489cc1

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2842,7 +2842,7 @@ public final <R> Maybe<R> flatMapSingleElement(final Function<? super T, ? exten
28422842
*/
28432843
@CheckReturnValue
28442844
@SchedulerSupport(SchedulerSupport.NONE)
2845-
public final Completable flatMapCompletable(final Function<? super T, ? extends Completable> mapper) {
2845+
public final Completable flatMapCompletable(final Function<? super T, ? extends CompletableSource> mapper) {
28462846
ObjectHelper.requireNonNull(mapper, "mapper is null");
28472847
return RxJavaPlugins.onAssembly(new MaybeFlatMapCompletable<T>(this, mapper));
28482848
}

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2097,7 +2097,7 @@ public final <R> Observable<R> flatMapObservable(Function<? super T, ? extends O
20972097
*/
20982098
@CheckReturnValue
20992099
@SchedulerSupport(SchedulerSupport.NONE)
2100-
public final Completable flatMapCompletable(final Function<? super T, ? extends Completable> mapper) {
2100+
public final Completable flatMapCompletable(final Function<? super T, ? extends CompletableSource> mapper) {
21012101
ObjectHelper.requireNonNull(mapper, "mapper is null");
21022102
return RxJavaPlugins.onAssembly(new SingleFlatMapCompletable<T>(this, mapper));
21032103
}

0 commit comments

Comments
 (0)