Use headers to send the request

openzipkin · Oct 15, 2020 · 79c9461 · 79c9461
1 parent 01046f8
commit 79c9461
Showing 1 changed file with 9 additions and 4 deletions.
diff --git a/...n-storage/elasticsearch/src/main/java/zipkin2/elasticsearch/internal/client/HttpCall.java b/...n-storage/elasticsearch/src/main/java/zipkin2/elasticsearch/internal/client/HttpCall.java
@@ -205,10 +205,15 @@ CompletableFuture<AggregatedHttpResponse> sendRequest() {
     final HttpResponse response;
     try (SafeCloseable ignored =
            Clients.withContextCustomizer(ctx -> ctx.logBuilder().name(name))) {
-      HttpRequestWriter httpRequest = HttpRequest.streaming(request.headers());
-      response = httpClient.execute(httpRequest);
-      request.writeBody(httpRequest::tryWrite);
-      httpRequest.close();
+      final RequestHeaders headers = request.headers();
+      if (headers.isEndOfStream()) {
+        response = httpClient.execute(headers);
+      } else {
+        HttpRequestWriter httpRequest = HttpRequest.streaming(headers);
+        response = httpClient.execute(httpRequest);
+        request.writeBody(httpRequest::tryWrite);
+        httpRequest.close();
+      }
     }
     CompletableFuture<AggregatedHttpResponse> responseFuture =
       RequestContext.mapCurrent(