ReactiveX
diff --git a/‎src/main/java/io/reactivex/rxjava3/core/Completable.java
Copy file name to clipboard
+151-104Lines changed: 151 additions & 104 deletions b/‎src/main/java/io/reactivex/rxjava3/core/Completable.java
Copy file name to clipboard
+151-104Lines changed: 151 additions & 104 deletions
diff --git a/‎src/main/java/io/reactivex/rxjava3/core/Flowable.java
Copy file name to clipboard
+946-670Lines changed: 946 additions & 670 deletions b/‎src/main/java/io/reactivex/rxjava3/core/Flowable.java
Copy file name to clipboard
+946-670Lines changed: 946 additions & 670 deletions
diff --git a/‎src/main/java/io/reactivex/rxjava3/core/Maybe.java
Copy file name to clipboard
+304-260Lines changed: 304 additions & 260 deletions b/‎src/main/java/io/reactivex/rxjava3/core/Maybe.java
Copy file name to clipboard
+304-260Lines changed: 304 additions & 260 deletions
diff --git a/‎src/main/java/io/reactivex/rxjava3/core/Notification.java
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/‎src/main/java/io/reactivex/rxjava3/core/Notification.java
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎src/main/java/io/reactivex/rxjava3/core/Observable.java
Copy file name to clipboard
+147-162Lines changed: 147 additions & 162 deletions b/‎src/main/java/io/reactivex/rxjava3/core/Observable.java
Copy file name to clipboard
+147-162Lines changed: 147 additions & 162 deletions
diff --git a/‎src/main/java/io/reactivex/rxjava3/core/Single.java
Copy file name to clipboard
+260-227Lines changed: 260 additions & 227 deletions b/‎src/main/java/io/reactivex/rxjava3/core/Single.java
Copy file name to clipboard
+260-227Lines changed: 260 additions & 227 deletions
diff --git a/‎src/test/java/io/reactivex/rxjava3/flowable/FlowableNullTests.java
Copy file name to clipboard
-2Lines changed: 0 additions & 2 deletions b/‎src/test/java/io/reactivex/rxjava3/flowable/FlowableNullTests.java
Copy file name to clipboard
-2Lines changed: 0 additions & 2 deletions
diff --git a/‎src/test/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableConcatMapEagerTest.java
Copy file name to clipboard
-2Lines changed: 0 additions & 2 deletions b/‎src/test/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableConcatMapEagerTest.java
Copy file name to clipboard
-2Lines changed: 0 additions & 2 deletions
diff --git a/‎src/test/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableMergeDelayErrorTest.java
Copy file name to clipboard
-1Lines changed: 0 additions & 1 deletion b/‎src/test/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableMergeDelayErrorTest.java
Copy file name to clipboard
-1Lines changed: 0 additions & 1 deletion
diff --git a/‎src/test/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableMergeTest.java
Copy file name to clipboard
-1Lines changed: 0 additions & 1 deletion b/‎src/test/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableMergeTest.java
Copy file name to clipboard
-1Lines changed: 0 additions & 1 deletion
@@ -27,7 +27,7 @@ public final class Notification<T> {
     final Object value;
 
     /** Not meant to be implemented externally. */
-    private Notification(Object value) {
+    private Notification(@Nullable Object value) {
         this.value = value;
     }
 
 
@@ -483,7 +483,6 @@ public void mergeArrayNull() {
         Flowable.mergeArray(128, 128, (Publisher<Object>[])null);
     }
 
-    @SuppressWarnings("unchecked")
     @Test(expected = NullPointerException.class)
     public void mergeArrayOneIsNull() {
         Flowable.mergeArray(128, 128, just1, null).blockingLast();
@@ -514,7 +513,6 @@ public void mergeDelayErrorArrayNull() {
         Flowable.mergeArrayDelayError(128, 128, (Publisher<Object>[])null);
     }
 
-    @SuppressWarnings("unchecked")
     @Test(expected = NullPointerException.class)
     public void mergeDelayErrorArrayOneIsNull() {
         Flowable.mergeArrayDelayError(128, 128, just1, null).blockingLast();
 
@@ -1210,7 +1210,6 @@ public void arrayDelayErrorMaxConcurrency() {
         PublishProcessor<Integer> pp2 = PublishProcessor.create();
         PublishProcessor<Integer> pp3 = PublishProcessor.create();
 
-        @SuppressWarnings("unchecked")
         TestSubscriber<Integer> ts = Flowable.concatArrayEagerDelayError(2, 2, pp1, pp2, pp3)
         .test();
 
@@ -1246,7 +1245,6 @@ public void arrayDelayErrorMaxConcurrencyErrorDelayed() {
         PublishProcessor<Integer> pp2 = PublishProcessor.create();
         PublishProcessor<Integer> pp3 = PublishProcessor.create();
 
-        @SuppressWarnings("unchecked")
         TestSubscriber<Integer> ts = Flowable.concatArrayEagerDelayError(2, 2, pp1, pp2, pp3)
         .test();
 
 
@@ -622,7 +622,6 @@ public void array() {
         }
     }
 
-    @SuppressWarnings("unchecked")
     @Test
     public void mergeArrayDelayError() {
         Flowable.mergeArrayDelayError(Flowable.just(1), Flowable.just(2))
 
@@ -1518,7 +1518,6 @@ public void array() {
         }
     }
 
-    @SuppressWarnings("unchecked")
     @Test
     public void mergeArray2() {
         Flowable.mergeArray(Flowable.just(1), Flowable.just(2))
Original file line number	Diff line number	Diff line change
`@@ -27,7 +27,7 @@ public final class Notification<T> {`
`27`	`27`	`final Object value;`
`28`	`28`
`29`	`29`	`/** Not meant to be implemented externally. */`
`30`		`- private Notification(Object value) {`
	`30`	`+ private Notification(@Nullable Object value) {`
`31`	`31`	`this.value = value;`
`32`	`32`	`}`
`33`	`33`
Original file line number	Diff line number	Diff line change
`@@ -483,7 +483,6 @@ public void mergeArrayNull() {`
`483`	`483`	`Flowable.mergeArray(128, 128, (Publisher<Object>[])null);`
`484`	`484`	`}`
`485`	`485`
`486`		`- @SuppressWarnings("unchecked")`
`487`	`486`	`@Test(expected = NullPointerException.class)`
`488`	`487`	`public void mergeArrayOneIsNull() {`
`489`	`488`	`Flowable.mergeArray(128, 128, just1, null).blockingLast();`
`@@ -514,7 +513,6 @@ public void mergeDelayErrorArrayNull() {`
`514`	`513`	`Flowable.mergeArrayDelayError(128, 128, (Publisher<Object>[])null);`
`515`	`514`	`}`
`516`	`515`
`517`		`- @SuppressWarnings("unchecked")`
`518`	`516`	`@Test(expected = NullPointerException.class)`
`519`	`517`	`public void mergeDelayErrorArrayOneIsNull() {`
`520`	`518`	`Flowable.mergeArrayDelayError(128, 128, just1, null).blockingLast();`
Original file line number	Diff line number	Diff line change
`@@ -622,7 +622,6 @@ public void array() {`
`622`	`622`	`}`
`623`	`623`	`}`
`624`	`624`
`625`		`- @SuppressWarnings("unchecked")`
`626`	`625`	`@Test`
`627`	`626`	`public void mergeArrayDelayError() {`
`628`	`627`	`Flowable.mergeArrayDelayError(Flowable.just(1), Flowable.just(2))`
Original file line number	Diff line number	Diff line change
`@@ -1518,7 +1518,6 @@ public void array() {`
`1518`	`1518`	`}`
`1519`	`1519`	`}`
`1520`	`1520`
`1521`		`- @SuppressWarnings("unchecked")`
`1522`	`1521`	`@Test`
`1523`	`1522`	`public void mergeArray2() {`
`1524`	`1523`	`Flowable.mergeArray(Flowable.just(1), Flowable.just(2))`