Skip to content

Commit 37f7d76

Browse files
wip
1 parent 6910c27 commit 37f7d76

File tree

2 files changed

+19
-12
lines changed

2 files changed

+19
-12
lines changed

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

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -44,17 +44,23 @@
4444
import com.fasterxml.jackson.core.JsonProcessingException;
4545
import com.fasterxml.jackson.databind.JsonNode;
4646
import com.fasterxml.jackson.databind.ObjectMapper;
47-
import com.influxdb.v3.client.InfluxDBApiNettyException;
4847
import io.netty.bootstrap.Bootstrap;
4948
import io.netty.buffer.Unpooled;
5049
import io.netty.channel.Channel;
51-
import io.netty.handler.codec.http.DefaultFullHttpRequest;
5250
import io.netty.channel.ChannelFuture;
5351
import io.netty.channel.ConnectTimeoutException;
5452
import io.netty.channel.EventLoopGroup;
5553
import io.netty.channel.oio.OioEventLoopGroup;
5654
import io.netty.channel.socket.oio.OioSocketChannel;
57-
import io.netty.handler.codec.http.*;
55+
import io.netty.handler.codec.http.DefaultFullHttpRequest;
56+
import io.netty.handler.codec.http.DefaultHttpHeaders;
57+
import io.netty.handler.codec.http.FullHttpResponse;
58+
import io.netty.handler.codec.http.HttpHeaders;
59+
import io.netty.handler.codec.http.HttpMethod;
60+
import io.netty.handler.codec.http.HttpRequest;
61+
import io.netty.handler.codec.http.HttpResponseStatus;
62+
import io.netty.handler.codec.http.HttpVersion;
63+
import io.netty.handler.codec.http.QueryStringEncoder;
5864
import io.netty.handler.logging.LogLevel;
5965
import io.netty.handler.logging.LoggingHandler;
6066
import io.netty.handler.proxy.HttpProxyHandler;
@@ -65,6 +71,7 @@
6571
import org.slf4j.LoggerFactory;
6672

6773
import com.influxdb.v3.client.InfluxDBApiException;
74+
import com.influxdb.v3.client.InfluxDBApiNettyException;
6875
import com.influxdb.v3.client.config.ClientConfig;
6976

7077
final class RestClient implements AutoCloseable {

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

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -38,15 +38,6 @@
3838
import javax.annotation.Nullable;
3939
import javax.net.ssl.SSLException;
4040

41-
import com.influxdb.v3.client.AbstractMockServerTest;
42-
import com.influxdb.v3.client.InfluxDBApiException;
43-
import com.influxdb.v3.client.InfluxDBApiNettyException;
44-
import com.influxdb.v3.client.InfluxDBClient;
45-
import com.influxdb.v3.client.TestUtils;
46-
import com.influxdb.v3.client.config.ClientConfig;
47-
import com.influxdb.v3.client.config.NettyHttpClientConfig;
48-
import com.influxdb.v3.client.write.WriteOptions;
49-
5041
import io.netty.handler.codec.http.DefaultHttpHeaders;
5142
import io.netty.handler.codec.http.HttpHeaders;
5243
import io.netty.handler.codec.http.HttpMethod;
@@ -63,6 +54,15 @@
6354
import org.junit.jupiter.api.AfterEach;
6455
import org.junit.jupiter.api.Test;
6556

57+
import com.influxdb.v3.client.AbstractMockServerTest;
58+
import com.influxdb.v3.client.InfluxDBApiException;
59+
import com.influxdb.v3.client.InfluxDBApiNettyException;
60+
import com.influxdb.v3.client.InfluxDBClient;
61+
import com.influxdb.v3.client.TestUtils;
62+
import com.influxdb.v3.client.config.ClientConfig;
63+
import com.influxdb.v3.client.config.NettyHttpClientConfig;
64+
import com.influxdb.v3.client.write.WriteOptions;
65+
6666
import static org.assertj.core.api.AssertionsForClassTypes.catchThrowable;
6767

6868
public class RestClientTest extends AbstractMockServerTest {

0 commit comments

Comments
 (0)