From f0bb6e0104cd4f6d66a8da00e4ebdc648cab9fcf Mon Sep 17 00:00:00 2001 From: Laura Trotta Date: Mon, 26 May 2025 17:39:01 +0200 Subject: [PATCH] avoid concurrent access to multibuffer entity iterator --- .../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 localIterator = this.buffers.iterator(); + if (localIterator.hasNext()) { + this.currentBuffer = localIterator.next().duplicate(); } else { this.currentBuffer = null; } + this.iterator = localIterator; } @Override