refactor: not use stream

Author: NguyenHoangSon96

src/main/java/com/influxdb/v3/client/internal/GrpcCallOptions.java

@@ -22,12 +22,9 @@
 package com.influxdb.v3.client.internal;
 
 import java.util.ArrayList;
-import java.util.Arrays;
 import java.util.List;
 import java.util.Objects;
-import java.util.Optional;
 import java.util.concurrent.Executor;
-import java.util.stream.Stream;
 import javax.annotation.Nonnull;
 import javax.annotation.Nullable;
 
@@ -72,9 +69,9 @@ private GrpcCallOptions(@Nonnull final Builder builder) {
      *
      * @return the default configuration of {@link GrpcCallOptions}.
      */
+    @Nonnull
     public static GrpcCallOptions getDefaultOptions() {
         GrpcCallOptions.Builder builder = new GrpcCallOptions.Builder();
-        builder.withMaxInboundMessageSize(Integer.MAX_VALUE);
         return builder.build();
     }
 
@@ -89,10 +86,12 @@ public static GrpcCallOptions getDefaultOptions() {
      */
     public static CallOption[] mergeCallOptions(@Nullable final CallOption[] baseCallOptions,
                                                 final CallOption... callOptions) {
-        return Stream.concat(
-                Arrays.stream(Optional.ofNullable(baseCallOptions).orElse(new CallOption[0])),
-                Arrays.stream(Optional.ofNullable(callOptions).orElse(new CallOption[0]))
-        ).toArray(CallOption[]::new);
+        CallOption[] base = baseCallOptions != null ? baseCallOptions : new CallOption[0];
+        CallOption[] additional = callOptions != null ? callOptions : new CallOption[0];
+        CallOption[] merged = new CallOption[base.length + additional.length];
+        System.arraycopy(base, 0, merged, 0, base.length);
+        System.arraycopy(additional, 0, merged, base.length, additional.length);
+        return merged;
     }
 
     /**

src/main/java/com/influxdb/v3/client/internal/InfluxDBClientImpl.java

@@ -342,8 +342,7 @@ private Stream<VectorSchemaRoot> queryData(@Nonnull final String query,
             }
         });
 
-        CallOption[] callOptions = options.grpcCallOptions() != null
-                ? options.grpcCallOptions().getCallOptions() : null;
+        CallOption[] callOptions = options.grpcCallOptions().getCallOptions();
         return flightSqlClient.execute(
                 query,
                 database,

src/main/java/com/influxdb/v3/client/query/QueryOptions.java

@@ -151,13 +151,14 @@ public Map<String, String> headersSafe() {
      * @param grpcCallOptions the grpcCallOptions
      */
     public void setGrpcCallOptions(@Nonnull final GrpcCallOptions grpcCallOptions) {
+        Arguments.checkNotNull(grpcCallOptions, "grpcCallOptions");
         this.grpcCallOptions = grpcCallOptions;
     }
 
     /**
      * @return the GrpcCallOptions object.
      */
-    @Nullable
+    @Nonnull
     public GrpcCallOptions grpcCallOptions() {
         return grpcCallOptions;
     }

src/test/java/com/influxdb/v3/client/internal/GrpcCallOptionsTest.java

@@ -27,6 +27,7 @@
 import org.junit.jupiter.api.Test;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNotEquals;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
 
 class GrpcCallOptionsTest {
@@ -118,4 +119,86 @@ public <T extends AbstractStub<T>> T wrapStub(final T stub) {
         };
     }
 
+    @Test
+    void testEqualsWithEqualObjects() {
+        GrpcCallOptions options1 = new GrpcCallOptions.Builder()
+                .withMaxInboundMessageSize(2000)
+                .withCompressorName("gzip")
+                .build();
+        GrpcCallOptions options2 = new GrpcCallOptions.Builder()
+                .withMaxInboundMessageSize(2000)
+                .withCompressorName("gzip")
+                .build();
+
+        assertEquals(options1, options2);
+    }
+
+    @Test
+    void testEqualsWithDifferentObjects() {
+        GrpcCallOptions options1 = new GrpcCallOptions.Builder()
+                .withMaxInboundMessageSize(2000)
+                .withCompressorName("gzip")
+                .build();
+        GrpcCallOptions options2 = new GrpcCallOptions.Builder()
+                .withMaxInboundMessageSize(1000)
+                .withCompressorName("deflate")
+                .build();
+
+        assertNotEquals(options1, options2);
+    }
+
+    @Test
+    void testEqualsWithNullAndDifferentClass() {
+        GrpcCallOptions options = new GrpcCallOptions.Builder()
+                .withMaxInboundMessageSize(2000)
+                .build();
+
+        assertNotEquals(null, options);
+        assertNotEquals(1, options);
+    }
+
+    @Test
+    void testHashCodeWithEqualObjects() {
+        GrpcCallOptions options1 = new GrpcCallOptions.Builder()
+                .withMaxInboundMessageSize(2000)
+                .withCompressorName("gzip")
+                .build();
+        GrpcCallOptions options2 = new GrpcCallOptions.Builder()
+                .withMaxInboundMessageSize(2000)
+                .withCompressorName("gzip")
+                .build();
+
+        assertEquals(options1.hashCode(), options2.hashCode());
+    }
+
+    @Test
+    void testHashCodeWithDifferentObjects() {
+        GrpcCallOptions options1 = new GrpcCallOptions.Builder()
+                .withMaxInboundMessageSize(2000)
+                .withCompressorName("gzip")
+                .build();
+        GrpcCallOptions options2 = new GrpcCallOptions.Builder()
+                .withMaxInboundMessageSize(1000)
+                .withCompressorName("deflate")
+                .build();
+
+        assertNotEquals(options1.hashCode(), options2.hashCode());
+    }
+
+    @Test
+    void testToString() {
+        GrpcCallOptions options = new GrpcCallOptions.Builder()
+                .withMaxInboundMessageSize(2000)
+                .withMaxOutboundMessageSize(5000)
+                .withCompressorName("gzip")
+                .build();
+
+        String expected = "GrpcCallOptions{deadline=null, "
+                + "executor=null, "
+                + "compressorName='gzip', "
+                + "waitForReady=null, "
+                + "maxInboundMessageSize=2000, "
+                + "maxOutboundMessageSize=5000}";
+        assertEquals(expected, options.toString());
+    }
 }