Use respondAndRelease

cbuescher · Oct 7, 2024 · 14a7dce · 14a7dce
1 parent 89201c7
commit 14a7dce
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...r/src/test/java/org/elasticsearch/action/search/SearchQueryThenFetchAsyncActionTests.java b/...r/src/test/java/org/elasticsearch/action/search/SearchQueryThenFetchAsyncActionTests.java
@@ -490,7 +490,7 @@ public void sendExecuteQuery(
                     queryResult.size(1);
                     successfulOps.incrementAndGet();
                     queryResult.incRef();
-                    new Thread(() -> listener.onResponse(queryResult)).start();
+                    new Thread(() -> ActionListener.respondAndRelease(listener, queryResult)).start();
                 } finally {
                     queryResult.decRef();
                 }
@@ -649,7 +649,7 @@ public void sendExecuteQuery(
                     queryResult.size(1);
                     successfulOps.incrementAndGet();
                     queryResult.incRef();
-                    new Thread(() -> listener.onResponse(queryResult)).start();
+                    new Thread(() -> ActionListener.respondAndRelease(listener, queryResult)).start();
                 } finally {
                     queryResult.decRef();
                 }