wip

Author: NguyenHoangSon96

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

@@ -135,7 +135,7 @@ final class RestClient implements AutoCloseable {
             }
         }
 
-        this.eventLoopGroup = new OioEventLoopGroup();
+        this.eventLoopGroup = new OioEventLoopGroup(1);
 
 //        this.promise = this.eventLoopGroup.next().newPromise();
 
@@ -262,9 +262,9 @@ public FullHttpResponse request(@Nonnull HttpMethod method,
             ChannelFuture channelFuture = getBootstrap().connect();
             if (!channelFuture.await(this.timeout.toMillis(), TimeUnit.MILLISECONDS)) {
                 throw new InfluxDBApiException(new ConnectTimeoutException());
-            } else {
-                this.channel = channelFuture.channel();
             }
+            this.channel = channelFuture.channel();
+
         }
 
         //fixme remove syncUninterruptibly

src/test/java/com/influxdb/v3/client/integration/E2ETest.java

@@ -228,7 +228,6 @@ public void testQueryRows() throws Exception {
                         timestamp
                 );
                 client.writeRecord(record, new WriteOptions(null, WritePrecision.MS, null));
-                Thread.sleep(2000);
                 testDatas.add(map);
             }
 
@@ -307,7 +306,6 @@ public void testQueryRowWithOptions() throws Exception {
                         timestamp
                 );
                 client.writeRecord(record, new WriteOptions(null, WritePrecision.MS, null));
-                Thread.sleep(2000);
                 testDatas.add(map);
             }