From c301570d51750c8c687519fe07526169d03941ae Mon Sep 17 00:00:00 2001
From: Laura Trotta <153528055+l-trotta@users.noreply.github.com>
Date: Tue, 24 Jun 2025 10:52:41 +0200
Subject: [PATCH] avoid concurrent access to multibuffer entity iterator
 (#1016) (#1028)

---
 .../clients/transport/rest_client/MultiBufferEntity.java   | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/java-client/src/main/java/co/elastic/clients/transport/rest_client/MultiBufferEntity.java b/java-client/src/main/java/co/elastic/clients/transport/rest_client/MultiBufferEntity.java
index f1a8e81db..cebbebd55 100644
--- a/java-client/src/main/java/co/elastic/clients/transport/rest_client/MultiBufferEntity.java
+++ b/java-client/src/main/java/co/elastic/clients/transport/rest_client/MultiBufferEntity.java
@@ -60,12 +60,13 @@ public void close() throws IOException {
     }
 
     private void init() {
-        this.iterator = buffers.iterator();
-        if (this.iterator.hasNext()) {
-            this.currentBuffer = this.iterator.next().duplicate();
+        Iterator<ByteBuffer> localIterator = this.buffers.iterator();
+        if (localIterator.hasNext()) {
+            this.currentBuffer = localIterator.next().duplicate();
         } else {
             this.currentBuffer = null;
         }
+        this.iterator = localIterator;
     }
 
     @Override