From cd6989f613cb80531c9fb77c5fcf3f64518c6795 Mon Sep 17 00:00:00 2001 From: Vova Stelmashchuk Date: Sat, 14 Mar 2020 22:54:34 +0200 Subject: [PATCH] Add see annotation for range operators --- src/main/java/io/reactivex/rxjava3/core/Flowable.java | 5 ++++- src/main/java/io/reactivex/rxjava3/core/Observable.java | 6 +++++- 2 files changed, 9 insertions(+), 2 deletions(-) diff --git a/src/main/java/io/reactivex/rxjava3/core/Flowable.java b/src/main/java/io/reactivex/rxjava3/core/Flowable.java index ddf5b3cf7b..33c89e1343 100644 --- a/src/main/java/io/reactivex/rxjava3/core/Flowable.java +++ b/src/main/java/io/reactivex/rxjava3/core/Flowable.java @@ -2921,11 +2921,12 @@ public static Flowable interval(long period, @NonNull TimeUnit unit, @NonN * @throws IllegalArgumentException * if {@code count} is less than zero, or if {@code start} + {@code count} − 1 exceeds * {@link Long#MAX_VALUE} + * @see #range(int, int) */ @CheckReturnValue + @NonNull @BackpressureSupport(BackpressureKind.ERROR) @SchedulerSupport(SchedulerSupport.COMPUTATION) - @NonNull public static Flowable intervalRange(long start, long count, long initialDelay, long period, @NonNull TimeUnit unit) { return intervalRange(start, count, initialDelay, period, unit, Schedulers.computation()); } @@ -4386,6 +4387,8 @@ public static Flowable never() { * if {@code count} is less than zero, or if {@code start} + {@code count} − 1 exceeds * {@link Integer#MAX_VALUE} * @see ReactiveX operators documentation: Range + * @see #rangeLong(long, long) + * @see #intervalRange(long, long, long, long, TimeUnit) */ @CheckReturnValue @BackpressureSupport(BackpressureKind.FULL) diff --git a/src/main/java/io/reactivex/rxjava3/core/Observable.java b/src/main/java/io/reactivex/rxjava3/core/Observable.java index c37da859fd..9972112585 100644 --- a/src/main/java/io/reactivex/rxjava3/core/Observable.java +++ b/src/main/java/io/reactivex/rxjava3/core/Observable.java @@ -2537,10 +2537,11 @@ public static Observable interval(long period, @NonNull TimeUnit unit, @No * @throws IllegalArgumentException * if {@code count} is negative, or if {@code start} + {@code count} − 1 exceeds * {@link Long#MAX_VALUE} + * @see #range(int, int) */ @CheckReturnValue - @SchedulerSupport(SchedulerSupport.COMPUTATION) @NonNull + @SchedulerSupport(SchedulerSupport.COMPUTATION) public static Observable intervalRange(long start, long count, long initialDelay, long period, @NonNull TimeUnit unit) { return intervalRange(start, count, initialDelay, period, unit, Schedulers.computation()); } @@ -3895,6 +3896,8 @@ public static Observable never() { * if {@code count} is negative, or if {@code start} + {@code count} − 1 exceeds * {@link Integer#MAX_VALUE} * @see ReactiveX operators documentation: Range + * @see #rangeLong(long, long) + * @see #intervalRange(long, long, long, long, TimeUnit) */ @CheckReturnValue @SchedulerSupport(SchedulerSupport.NONE) @@ -3933,6 +3936,7 @@ public static Observable range(int start, int count) { * if {@code count} is negative, or if {@code start} + {@code count} − 1 exceeds * {@link Long#MAX_VALUE} * @see ReactiveX operators documentation: Range + * @see #intervalRange(long, long, long, long, TimeUnit) */ @CheckReturnValue @SchedulerSupport(SchedulerSupport.NONE)