Skip to content

Commit 795b1de

Browse files
wip
1 parent 231a05b commit 795b1de

File tree

2 files changed

+0
-3
lines changed

2 files changed

+0
-3
lines changed

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -382,7 +382,6 @@ private <T> void writeData(@Nonnull final List<T> data, @Nonnull final WriteOpti
382382
headers.putAll(options.headersSafe());
383383

384384
try {
385-
//fixme should body string or byte, gzip?
386385
restClient.request(HttpMethod.POST, path, headers, body, queryParams);
387386
} catch (InfluxDBApiNettyException e) {
388387
if (noSync && e.statusCode() == HttpResponseStatus.METHOD_NOT_ALLOWED.code()) {

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

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -254,13 +254,11 @@ public FullHttpResponse request(@Nonnull final HttpMethod method,
254254

255255
if (this.channel == null || !this.channel.isOpen()) {
256256
ChannelFuture channelFuture = getBootstrap().connect();
257-
//fixme this is the connection timeout not read timeout
258257
if (!channelFuture.await(this.timeout.toMillis(), TimeUnit.MILLISECONDS)) {
259258
throw new InfluxDBApiException(new ConnectTimeoutException());
260259
}
261260
this.channel = channelFuture.channel();
262261
}
263-
//fixme remove syncUninterruptibly
264262
this.channel.writeAndFlush(request).sync();
265263

266264
fullHttpResponse = this.clientHandler.getResponseFuture().get();

0 commit comments

Comments
 (0)