Supressing warnings

Author: Michael-A-McMahon

src/main/java/oracle/r2dbc/impl/OracleStatementImpl.java

@@ -1457,7 +1457,7 @@ private JdbcBatch(
      */
     @Override
     protected Publisher<Void> bind() {
-      @SuppressWarnings("unchecked")
+      @SuppressWarnings({"unchecked","rawtypes"})
       Publisher<Void>[] bindPublishers = new Publisher[batchSize];
       for (int i = 0; i < batchSize; i++) {
         bindPublishers[i] = Flux.concat(

src/test/java/oracle/r2dbc/impl/OracleStatementImplTest.java

@@ -56,7 +56,6 @@
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.stream.Collectors;
 import java.util.stream.IntStream;
-import java.util.stream.LongStream;
 import java.util.stream.Stream;
 
 import static java.lang.String.format;
@@ -2158,6 +2157,7 @@ public void testUsingWhenCancel() {
         "CREATE TABLE testUsingWhenCancel (value NUMBER)"));
 
       // Use more threads than what the FJP has available
+      @SuppressWarnings({"unchecked","rawtypes"})
       Publisher<Boolean>[] publishers =
         new Publisher[ForkJoinPool.getCommonPoolParallelism() * 4];
 
@@ -2301,6 +2301,7 @@ ConnectionFactoryOptions.PASSWORD, password())
   private void verifyConcurrentExecute(Connection connection) {
 
     // Create many statements and execute them in parallel.
+    @SuppressWarnings({"unchecked","rawtypes"})
     Publisher<Integer>[] publishers = new Publisher[8];
 
     for (int i = 0; i < publishers.length; i++) {
@@ -2332,6 +2333,7 @@ private void verifyConcurrentFetch(Connection connection) {
         "CREATE TABLE testConcurrentFetch (value NUMBER)"));
 
       // Create many statements and execute them in parallel.
+      @SuppressWarnings({"unchecked","rawtypes"})
       Publisher<Long>[] publishers = new Publisher[8];
 
       for (int i = 0; i < publishers.length; i++) {
@@ -2365,6 +2367,7 @@ private void verifyConcurrentFetch(Connection connection) {
         Flux.merge(publishers));
 
       // Create publishers that fetch rows in parallel
+      @SuppressWarnings({"unchecked","rawtypes"})
       Publisher<List<Integer>>[] fetchPublishers =
         new Publisher[publishers.length];