Fix paramvalidator

akarnokd · akarnokd · commit 6d985df8351e · 2022-06-06T09:51:32.000Z
diff --git a/src/test/java/io/reactivex/rxjava3/validators/ParamValidationCheckerTest.java b/src/test/java/io/reactivex/rxjava3/validators/ParamValidationCheckerTest.java
@@ -560,6 +560,7 @@ public void checkParallelFlowable() {
         for (Class<?> interfaces : AllFunctionals.class.getInterfaces()) {
             defaultValues.put(interfaces, af);
         }
+        defaultValues.put(Subscriber.class, af);
         defaultValues.put(TimeUnit.class, TimeUnit.SECONDS);
         defaultValues.put(Scheduler.class, Schedulers.single());
         defaultValues.put(BackpressureStrategy.class, BackpressureStrategy.MISSING);

Original file line number	Diff line number	Diff line change
`@@ -560,6 +560,7 @@ public void checkParallelFlowable() {`
`560`	`560`	`for (Class<?> interfaces : AllFunctionals.class.getInterfaces()) {`
`561`	`561`	`defaultValues.put(interfaces, af);`
`562`	`562`	`}`
	`563`	`+ defaultValues.put(Subscriber.class, af);`
`563`	`564`	`defaultValues.put(TimeUnit.class, TimeUnit.SECONDS);`
`564`	`565`	`defaultValues.put(Scheduler.class, Schedulers.single());`
`565`	`566`	`defaultValues.put(BackpressureStrategy.class, BackpressureStrategy.MISSING);`