Allow nullable acc. type on Observable.collect too (supplement #7590)

akarnokd · akarnokd · commit a57ad01c044b · 2023-08-23T12:47:36.000+02:00
diff --git a/src/main/java/io/reactivex/rxjava3/core/Observable.java b/src/main/java/io/reactivex/rxjava3/core/Observable.java
@@ -16985,7 +16985,7 @@ public final TestObserver<T> test(boolean dispose) { // NoPMD
     @CheckReturnValue
     @SchedulerSupport(SchedulerSupport.NONE)
     @NonNull
-    public final <@NonNull R, @NonNull A> Single<R> collect(@NonNull Collector<? super T, A, R> collector) {
+    public final <@NonNull R, @Nullable A> Single<R> collect(@NonNull Collector<? super T, A, R> collector) {
         Objects.requireNonNull(collector, "collector is null");
         return RxJavaPlugins.onAssembly(new ObservableCollectWithCollectorSingle<>(this, collector));
     }

Original file line number	Diff line number	Diff line change
`@@ -16985,7 +16985,7 @@ public final TestObserver<T> test(boolean dispose) { // NoPMD`
`16985`	`16985`	`@CheckReturnValue`
`16986`	`16986`	`@SchedulerSupport(SchedulerSupport.NONE)`
`16987`	`16987`	`@NonNull`
`16988`		`- public final <@NonNull R, @NonNull A> Single<R> collect(@NonNull Collector<? super T, A, R> collector) {`
	`16988`	`+ public final <@NonNull R, @Nullable A> Single<R> collect(@NonNull Collector<? super T, A, R> collector) {`
`16989`	`16989`	`Objects.requireNonNull(collector, "collector is null");`
`16990`	`16990`	`return RxJavaPlugins.onAssembly(new ObservableCollectWithCollectorSingle<>(this, collector));`
`16991`	`16991`	`}`