Skip to content

Commit abd445b

Browse files
freakomonkfreakomonk
committed
Adding NonNull annotation
1 parent 7058126 commit abd445b

File tree

2 files changed

+25
-0
lines changed

2 files changed

+25
-0
lines changed

‎src/main/java/io/reactivex/Observable.java‎

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1735,6 +1735,7 @@ public static <T> Observable<T> error(final Throwable exception) {
17351735
*/
17361736
@CheckReturnValue
17371737
@SchedulerSupport(SchedulerSupport.NONE)
1738+
@NonNull
17381739
public static <T> Observable<T> fromArray(T... items) {
17391740
ObjectHelper.requireNonNull(items, "items is null");
17401741
if (items.length == 0) {
@@ -1775,6 +1776,7 @@ public static <T> Observable<T> fromArray(T... items) {
17751776
* @since 2.0
17761777
*/
17771778
@CheckReturnValue
1779+
@NonNull
17781780
@SchedulerSupport(SchedulerSupport.NONE)
17791781
public static <T> Observable<T> fromCallable(Callable<? extends T> supplier) {
17801782
ObjectHelper.requireNonNull(supplier, "supplier is null");
@@ -1808,6 +1810,7 @@ public static <T> Observable<T> fromCallable(Callable<? extends T> supplier) {
18081810
* @see <a href="http://reactivex.io/documentation/operators/from.html">ReactiveX operators documentation: From</a>
18091811
*/
18101812
@CheckReturnValue
1813+
@NonNull
18111814
@SchedulerSupport(SchedulerSupport.NONE)
18121815
public static <T> Observable<T> fromFuture(Future<? extends T> future) {
18131816
ObjectHelper.requireNonNull(future, "future is null");
@@ -1845,6 +1848,7 @@ public static <T> Observable<T> fromFuture(Future<? extends T> future) {
18451848
* @see <a href="http://reactivex.io/documentation/operators/from.html">ReactiveX operators documentation: From</a>
18461849
*/
18471850
@CheckReturnValue
1851+
@NonNull
18481852
@SchedulerSupport(SchedulerSupport.NONE)
18491853
public static <T> Observable<T> fromFuture(Future<? extends T> future, long timeout, TimeUnit unit) {
18501854
ObjectHelper.requireNonNull(future, "future is null");
@@ -1886,6 +1890,7 @@ public static <T> Observable<T> fromFuture(Future<? extends T> future, long time
18861890
* @see <a href="http://reactivex.io/documentation/operators/from.html">ReactiveX operators documentation: From</a>
18871891
*/
18881892
@CheckReturnValue
1893+
@NonNull
18891894
@SchedulerSupport(SchedulerSupport.CUSTOM)
18901895
public static <T> Observable<T> fromFuture(Future<? extends T> future, long timeout, TimeUnit unit, Scheduler scheduler) {
18911896
ObjectHelper.requireNonNull(scheduler, "scheduler is null");
@@ -1921,6 +1926,7 @@ public static <T> Observable<T> fromFuture(Future<? extends T> future, long time
19211926
* @see <a href="http://reactivex.io/documentation/operators/from.html">ReactiveX operators documentation: From</a>
19221927
*/
19231928
@CheckReturnValue
1929+
@NonNull
19241930
@SchedulerSupport(SchedulerSupport.CUSTOM)
19251931
public static <T> Observable<T> fromFuture(Future<? extends T> future, Scheduler scheduler) {
19261932
ObjectHelper.requireNonNull(scheduler, "scheduler is null");
@@ -1946,6 +1952,7 @@ public static <T> Observable<T> fromFuture(Future<? extends T> future, Scheduler
19461952
* @see <a href="http://reactivex.io/documentation/operators/from.html">ReactiveX operators documentation: From</a>
19471953
*/
19481954
@CheckReturnValue
1955+
@NonNull
19491956
@SchedulerSupport(SchedulerSupport.NONE)
19501957
public static <T> Observable<T> fromIterable(Iterable<? extends T> source) {
19511958
ObjectHelper.requireNonNull(source, "source is null");
@@ -1982,6 +1989,7 @@ public static <T> Observable<T> fromIterable(Iterable<? extends T> source) {
19821989
*/
19831990
@BackpressureSupport(BackpressureKind.UNBOUNDED_IN)
19841991
@CheckReturnValue
1992+
@NonNull
19851993
@SchedulerSupport(SchedulerSupport.NONE)
19861994
public static <T> Observable<T> fromPublisher(Publisher<? extends T> publisher) {
19871995
ObjectHelper.requireNonNull(publisher, "publisher is null");
@@ -2010,6 +2018,7 @@ public static <T> Observable<T> fromPublisher(Publisher<? extends T> publisher)
20102018
* @return the new Observable instance
20112019
*/
20122020
@CheckReturnValue
2021+
@NonNull
20132022
@SchedulerSupport(SchedulerSupport.NONE)
20142023
public static <T> Observable<T> generate(final Consumer<Emitter<T>> generator) {
20152024
ObjectHelper.requireNonNull(generator, "generator is null");
@@ -2041,6 +2050,7 @@ public static <T> Observable<T> generate(final Consumer<Emitter<T>> generator) {
20412050
* @return the new Observable instance
20422051
*/
20432052
@CheckReturnValue
2053+
@NonNull
20442054
@SchedulerSupport(SchedulerSupport.NONE)
20452055
public static <T, S> Observable<T> generate(Callable<S> initialState, final BiConsumer<S, Emitter<T>> generator) {
20462056
ObjectHelper.requireNonNull(generator, "generator is null");
@@ -2073,6 +2083,7 @@ public static <T, S> Observable<T> generate(Callable<S> initialState, final BiCo
20732083
* @return the new Observable instance
20742084
*/
20752085
@CheckReturnValue
2086+
@NonNull
20762087
@SchedulerSupport(SchedulerSupport.NONE)
20772088
public static <T, S> Observable<T> generate(
20782089
final Callable<S> initialState,
@@ -2139,6 +2150,7 @@ public static <T, S> Observable<T> generate(Callable<S> initialState, BiFunction
21392150
* @return the new Observable instance
21402151
*/
21412152
@CheckReturnValue
2153+
@NonNull
21422154
@SchedulerSupport(SchedulerSupport.NONE)
21432155
public static <T, S> Observable<T> generate(Callable<S> initialState, BiFunction<S, Emitter<T>, S> generator,
21442156
Consumer<? super S> disposeState) {
@@ -2199,6 +2211,7 @@ public static Observable<Long> interval(long initialDelay, long period, TimeUnit
21992211
* @since 1.0.12
22002212
*/
22012213
@CheckReturnValue
2214+
@NonNull
22022215
@SchedulerSupport(SchedulerSupport.CUSTOM)
22032216
public static Observable<Long> interval(long initialDelay, long period, TimeUnit unit, Scheduler scheduler) {
22042217
ObjectHelper.requireNonNull(unit, "unit is null");
@@ -2295,6 +2308,7 @@ public static Observable<Long> intervalRange(long start, long count, long initia
22952308
* @return the new Observable instance
22962309
*/
22972310
@CheckReturnValue
2311+
@NonNull
22982312
@SchedulerSupport(SchedulerSupport.CUSTOM)
22992313
public static Observable<Long> intervalRange(long start, long count, long initialDelay, long period, TimeUnit unit, Scheduler scheduler) {
23002314
if (count < 0) {
@@ -2344,6 +2358,7 @@ public static Observable<Long> intervalRange(long start, long count, long initia
23442358
* @see #fromIterable(Iterable)
23452359
*/
23462360
@CheckReturnValue
2361+
@NonNull
23472362
@SchedulerSupport(SchedulerSupport.NONE)
23482363
public static <T> Observable<T> just(T item) {
23492364
ObjectHelper.requireNonNull(item, "The item is null");
@@ -2370,6 +2385,7 @@ public static <T> Observable<T> just(T item) {
23702385
*/
23712386
@SuppressWarnings("unchecked")
23722387
@CheckReturnValue
2388+
@NonNull
23732389
@SchedulerSupport(SchedulerSupport.NONE)
23742390
public static <T> Observable<T> just(T item1, T item2) {
23752391
ObjectHelper.requireNonNull(item1, "The first item is null");
@@ -2400,6 +2416,7 @@ public static <T> Observable<T> just(T item1, T item2) {
24002416
*/
24012417
@SuppressWarnings("unchecked")
24022418
@CheckReturnValue
2419+
@NonNull
24032420
@SchedulerSupport(SchedulerSupport.NONE)
24042421
public static <T> Observable<T> just(T item1, T item2, T item3) {
24052422
ObjectHelper.requireNonNull(item1, "The first item is null");
@@ -2433,6 +2450,7 @@ public static <T> Observable<T> just(T item1, T item2, T item3) {
24332450
*/
24342451
@SuppressWarnings("unchecked")
24352452
@CheckReturnValue
2453+
@NonNull
24362454
@SchedulerSupport(SchedulerSupport.NONE)
24372455
public static <T> Observable<T> just(T item1, T item2, T item3, T item4) {
24382456
ObjectHelper.requireNonNull(item1, "The first item is null");
@@ -2469,6 +2487,7 @@ public static <T> Observable<T> just(T item1, T item2, T item3, T item4) {
24692487
*/
24702488
@SuppressWarnings("unchecked")
24712489
@CheckReturnValue
2490+
@NonNull
24722491
@SchedulerSupport(SchedulerSupport.NONE)
24732492
public static <T> Observable<T> just(T item1, T item2, T item3, T item4, T item5) {
24742493
ObjectHelper.requireNonNull(item1, "The first item is null");
@@ -2508,6 +2527,7 @@ public static <T> Observable<T> just(T item1, T item2, T item3, T item4, T item5
25082527
*/
25092528
@SuppressWarnings("unchecked")
25102529
@CheckReturnValue
2530+
@NonNull
25112531
@SchedulerSupport(SchedulerSupport.NONE)
25122532
public static <T> Observable<T> just(T item1, T item2, T item3, T item4, T item5, T item6) {
25132533
ObjectHelper.requireNonNull(item1, "The first item is null");
@@ -2550,6 +2570,7 @@ public static <T> Observable<T> just(T item1, T item2, T item3, T item4, T item5
25502570
*/
25512571
@SuppressWarnings("unchecked")
25522572
@CheckReturnValue
2573+
@NonNull
25532574
@SchedulerSupport(SchedulerSupport.NONE)
25542575
public static <T> Observable<T> just(T item1, T item2, T item3, T item4, T item5, T item6, T item7) {
25552576
ObjectHelper.requireNonNull(item1, "The first item is null");
@@ -2595,6 +2616,7 @@ public static <T> Observable<T> just(T item1, T item2, T item3, T item4, T item5
25952616
*/
25962617
@SuppressWarnings("unchecked")
25972618
@CheckReturnValue
2619+
@NonNull
25982620
@SchedulerSupport(SchedulerSupport.NONE)
25992621
public static <T> Observable<T> just(T item1, T item2, T item3, T item4, T item5, T item6, T item7, T item8) {
26002622
ObjectHelper.requireNonNull(item1, "The first item is null");
@@ -2643,6 +2665,7 @@ public static <T> Observable<T> just(T item1, T item2, T item3, T item4, T item5
26432665
*/
26442666
@SuppressWarnings("unchecked")
26452667
@CheckReturnValue
2668+
@NonNull
26462669
@SchedulerSupport(SchedulerSupport.NONE)
26472670
public static <T> Observable<T> just(T item1, T item2, T item3, T item4, T item5, T item6, T item7, T item8, T item9) {
26482671
ObjectHelper.requireNonNull(item1, "The first item is null");
@@ -2694,6 +2717,7 @@ public static <T> Observable<T> just(T item1, T item2, T item3, T item4, T item5
26942717
*/
26952718
@SuppressWarnings("unchecked")
26962719
@CheckReturnValue
2720+
@NonNull
26972721
@SchedulerSupport(SchedulerSupport.NONE)
26982722
public static <T> Observable<T> just(T item1, T item2, T item3, T item4, T item5, T item6, T item7, T item8, T item9, T item10) {
26992723
ObjectHelper.requireNonNull(item1, "The first item is null");

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -813,6 +813,7 @@ public static <T> Single<T> fromObservable(ObservableSource<? extends T> observa
813813
*/
814814
@CheckReturnValue
815815
@SchedulerSupport(SchedulerSupport.NONE)
816+
@NonNull
816817
public static <T> Single<T> just(final T item) {
817818
ObjectHelper.requireNonNull(item, "value is null");
818819
return RxJavaPlugins.onAssembly(new SingleJust<T>(item));

0 commit comments

Comments
 (0)