File tree 1 file changed +0
-3
lines changed
src/main/java/io/reactivex/rxjava3/core 1 file changed +0
-3
lines changed Original file line number Diff line number Diff line change @@ -5520,7 +5520,6 @@ public final T blockingFirst(@NonNull T defaultItem) {
5520
5520
* @see #blockingForEach(Consumer, int)
5521
5521
*/
5522
5522
@SchedulerSupport(SchedulerSupport.NONE)
5523
- @NonNull
5524
5523
public final void blockingForEach(@NonNull Consumer<? super T> onNext) {
5525
5524
blockingForEach(onNext, bufferSize());
5526
5525
}
@@ -5560,7 +5559,6 @@ public final void blockingForEach(@NonNull Consumer<? super T> onNext) {
5560
5559
* @see #subscribe(Consumer)
5561
5560
*/
5562
5561
@SchedulerSupport(SchedulerSupport.NONE)
5563
- @NonNull
5564
5562
public final void blockingForEach(@NonNull Consumer<? super T> onNext, int capacityHint) {
5565
5563
Objects.requireNonNull(onNext, "onNext is null");
5566
5564
Iterator<T> it = blockingIterable(capacityHint).iterator();
@@ -12036,7 +12034,6 @@ public final Observable<T> retryWhen(
12036
12034
* @throws NullPointerException if {@code observer} is {@code null}
12037
12035
*/
12038
12036
@SchedulerSupport(SchedulerSupport.NONE)
12039
- @NonNull
12040
12037
public final void safeSubscribe(@NonNull Observer<? super T> observer) {
12041
12038
Objects.requireNonNull(observer, "observer is null");
12042
12039
if (observer instanceof SafeObserver) {
You can’t perform that action at this time.
0 commit comments