File tree Expand file tree Collapse file tree 10 files changed +16
-16
lines changed
src/main/java/io/reactivex Expand file tree Collapse file tree 10 files changed +16
-16
lines changed Original file line number Diff line number Diff line change @@ -914,7 +914,7 @@ public final Completable andThen(CompletableSource next) {
914
914
* This allows fluent conversion to any other type.
915
915
* <dl>
916
916
* <dt><b>Scheduler:</b></dt>
917
- * <dd>{@code to } does not operate by default on a particular {@link Scheduler}.</dd>
917
+ * <dd>{@code as } does not operate by default on a particular {@link Scheduler}.</dd>
918
918
* </dl>
919
919
*
920
920
* @param <R> the resulting object type
@@ -925,7 +925,7 @@ public final Completable andThen(CompletableSource next) {
925
925
@ Experimental
926
926
@ CheckReturnValue
927
927
@ SchedulerSupport (SchedulerSupport .NONE )
928
- public final <R > R as (CompletableConverter <? extends R > converter ) {
928
+ public final <R > R as (@ NonNull CompletableConverter <? extends R > converter ) {
929
929
try {
930
930
return ObjectHelper .requireNonNull (converter , "converter is null" ).apply (this );
931
931
} catch (Throwable ex ) {
Original file line number Diff line number Diff line change 24
24
@ Experimental
25
25
public interface CompletableConverter <R > {
26
26
/**
27
- * Applies a function to the upstream Completable and returns a converted value of type <R> .
27
+ * Applies a function to the upstream Completable and returns a converted value of type {@code R} .
28
28
*
29
29
* @param upstream the upstream Completable instance
30
30
* @return the converted value
Original file line number Diff line number Diff line change @@ -5245,7 +5245,7 @@ public final Single<Boolean> any(Predicate<? super T> predicate) {
5245
5245
* <dt><b>Backpressure:</b></dt>
5246
5246
* <dd>The backpressure behavior depends on what happens in the {@code converter} function.</dd>
5247
5247
* <dt><b>Scheduler:</b></dt>
5248
- * <dd>{@code to } does not operate by default on a particular {@link Scheduler}.</dd>
5248
+ * <dd>{@code as } does not operate by default on a particular {@link Scheduler}.</dd>
5249
5249
* </dl>
5250
5250
*
5251
5251
* @param <R> the resulting object type
@@ -5257,7 +5257,7 @@ public final Single<Boolean> any(Predicate<? super T> predicate) {
5257
5257
@CheckReturnValue
5258
5258
@BackpressureSupport(BackpressureKind.SPECIAL)
5259
5259
@SchedulerSupport(SchedulerSupport.NONE)
5260
- public final <R> R as(FlowableConverter<T, ? extends R> converter) {
5260
+ public final <R> R as(@NonNull FlowableConverter<T, ? extends R> converter) {
5261
5261
try {
5262
5262
return ObjectHelper.requireNonNull(converter, "converter is null").apply(this);
5263
5263
} catch (Throwable ex) {
Original file line number Diff line number Diff line change 25
25
@ Experimental
26
26
public interface FlowableConverter <T , R > {
27
27
/**
28
- * Applies a function to the upstream Flowable and returns a converted value of type <R> .
28
+ * Applies a function to the upstream Flowable and returns a converted value of type {@code R} .
29
29
*
30
30
* @param upstream the upstream Flowable instance
31
31
* @return the converted value
Original file line number Diff line number Diff line change @@ -1995,7 +1995,7 @@ public final Maybe<T> ambWith(MaybeSource<? extends T> other) {
1995
1995
* This allows fluent conversion to any other type.
1996
1996
* <dl>
1997
1997
* <dt><b>Scheduler:</b></dt>
1998
- * <dd>{@code to } does not operate by default on a particular {@link Scheduler}.</dd>
1998
+ * <dd>{@code as } does not operate by default on a particular {@link Scheduler}.</dd>
1999
1999
* </dl>
2000
2000
*
2001
2001
* @param <R> the resulting object type
@@ -2006,7 +2006,7 @@ public final Maybe<T> ambWith(MaybeSource<? extends T> other) {
2006
2006
@ Experimental
2007
2007
@ CheckReturnValue
2008
2008
@ SchedulerSupport (SchedulerSupport .NONE )
2009
- public final <R > R as (MaybeConverter <T , ? extends R > converter ) {
2009
+ public final <R > R as (@ NonNull MaybeConverter <T , ? extends R > converter ) {
2010
2010
try {
2011
2011
return ObjectHelper .requireNonNull (converter , "converter is null" ).apply (this );
2012
2012
} catch (Throwable ex ) {
Original file line number Diff line number Diff line change 25
25
@ Experimental
26
26
public interface MaybeConverter <T , R > {
27
27
/**
28
- * Applies a function to the upstream Maybe and returns a converted value of type <R> .
28
+ * Applies a function to the upstream Maybe and returns a converted value of type {@code R} .
29
29
*
30
30
* @param upstream the upstream Maybe instance
31
31
* @return the converted value
Original file line number Diff line number Diff line change @@ -4806,7 +4806,7 @@ public final Single<Boolean> any(Predicate<? super T> predicate) {
4806
4806
* This allows fluent conversion to any other type.
4807
4807
* <dl>
4808
4808
* <dt><b>Scheduler:</b></dt>
4809
- * <dd>{@code to } does not operate by default on a particular {@link Scheduler}.</dd>
4809
+ * <dd>{@code as } does not operate by default on a particular {@link Scheduler}.</dd>
4810
4810
* </dl>
4811
4811
*
4812
4812
* @param <R> the resulting object type
@@ -4817,7 +4817,7 @@ public final Single<Boolean> any(Predicate<? super T> predicate) {
4817
4817
@Experimental
4818
4818
@CheckReturnValue
4819
4819
@SchedulerSupport(SchedulerSupport.NONE)
4820
- public final <R> R as(ObservableConverter<T, ? extends R> converter) {
4820
+ public final <R> R as(@NonNull ObservableConverter<T, ? extends R> converter) {
4821
4821
try {
4822
4822
return ObjectHelper.requireNonNull(converter, "converter is null").apply(this);
4823
4823
} catch (Throwable ex) {
Original file line number Diff line number Diff line change 25
25
@ Experimental
26
26
public interface ObservableConverter <T , R > {
27
27
/**
28
- * Applies a function to the upstream Observable and returns a converted value of type <R> .
28
+ * Applies a function to the upstream Observable and returns a converted value of type {@code R} .
29
29
*
30
30
* @param upstream the upstream Observable instance
31
31
* @return the converted value
Original file line number Diff line number Diff line change @@ -1528,7 +1528,7 @@ public final Single<T> ambWith(SingleSource<? extends T> other) {
1528
1528
* This allows fluent conversion to any other type.
1529
1529
* <dl>
1530
1530
* <dt><b>Scheduler:</b></dt>
1531
- * <dd>{@code to } does not operate by default on a particular {@link Scheduler}.</dd>
1531
+ * <dd>{@code as } does not operate by default on a particular {@link Scheduler}.</dd>
1532
1532
* </dl>
1533
1533
*
1534
1534
* @param <R> the resulting object type
@@ -1539,7 +1539,7 @@ public final Single<T> ambWith(SingleSource<? extends T> other) {
1539
1539
@ Experimental
1540
1540
@ CheckReturnValue
1541
1541
@ SchedulerSupport (SchedulerSupport .NONE )
1542
- public final <R > R as (SingleConverter <T , ? extends R > converter ) {
1542
+ public final <R > R as (@ NonNull SingleConverter <T , ? extends R > converter ) {
1543
1543
try {
1544
1544
return ObjectHelper .requireNonNull (converter , "converter is null" ).apply (this );
1545
1545
} catch (Throwable ex ) {
Original file line number Diff line number Diff line change 16
16
import io .reactivex .annotations .*;
17
17
18
18
/**
19
- * Convenience interface and callback used by the {@link Single#as} operator to turn an Single into another
19
+ * Convenience interface and callback used by the {@link Single#as} operator to turn a Single into another
20
20
* value fluently.
21
21
*
22
22
* @param <T> the upstream type
25
25
@ Experimental
26
26
public interface SingleConverter <T , R > {
27
27
/**
28
- * Applies a function to the upstream Single and returns a converted value of type <R> .
28
+ * Applies a function to the upstream Single and returns a converted value of type {@code R} .
29
29
*
30
30
* @param upstream the upstream Single instance
31
31
* @return the converted value
You can’t perform that action at this time.
0 commit comments