Skip to content

Commit b1a301d

Browse files
author
Michel
committed
Set keep-alive header explicit, as at least Localstack api gateway closes the connection. localstack/localstack#1570
1 parent a3d5aa6 commit b1a301d

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

src/main/java/io/reactiverse/awssdk/VertxNioAsyncHttpClient.java

+2-5
Original file line numberDiff line numberDiff line change
@@ -5,11 +5,7 @@
55
import io.reactiverse.awssdk.reactivestreams.ReadStreamPublisher;
66
import io.vertx.core.Context;
77
import io.vertx.core.Vertx;
8-
import io.vertx.core.http.HttpClient;
9-
import io.vertx.core.http.HttpClientOptions;
10-
import io.vertx.core.http.HttpClientRequest;
11-
import io.vertx.core.http.HttpMethod;
12-
import io.vertx.core.http.RequestOptions;
8+
import io.vertx.core.http.*;
139
import software.amazon.awssdk.http.SdkHttpFullResponse;
1410
import software.amazon.awssdk.http.SdkHttpRequest;
1511
import software.amazon.awssdk.http.SdkHttpResponse;
@@ -58,6 +54,7 @@ void executeOnContext(AsyncExecuteRequest asyncExecuteRequest, CompletableFuture
5854
request.headers().forEach((headerName, headerValues) ->
5955
vRequest.putHeader(headerName, String.join(",", headerValues))
6056
);
57+
vRequest.putHeader(HttpHeaders.CONNECTION, HttpHeaders.KEEP_ALIVE);
6158
vRequest.exceptionHandler(error -> {
6259
responseHandler.onError(error);
6360
fut.completeExceptionally(error);

0 commit comments

Comments
 (0)