test(batch): send acks asynchronously

bevzzz · bevzzz · commit a443ea67cdd3 · 2026-03-27T15:01:37.000+01:00
diff --git a/src/test/java/io/weaviate/client6/v1/api/collections/batch/BatchContextTest.java b/src/test/java/io/weaviate/client6/v1/api/collections/batch/BatchContextTest.java
@@ -549,7 +549,7 @@ public void test_startAfterClose() throws Exception {
    */
   private List<String> recvDataAndAck() throws InterruptedException {
     List<String> received = recvData();
-    out.emitEvent(new Event.Acks(received));
+    out.emitEventAsync(new Event.Acks(received));
     return received;
   }
 

Original file line number	Diff line number	Diff line change
`@@ -549,7 +549,7 @@ public void test_startAfterClose() throws Exception {`
`549`	`549`	`*/`
`550`	`550`	`private List<String> recvDataAndAck() throws InterruptedException {`
`551`	`551`	`List<String> received = recvData();`
`552`		`- out.emitEvent(new Event.Acks(received));`
	`552`	`+ out.emitEventAsync(new Event.Acks(received));`
`553`	`553`	`return received;`
`554`	`554`	`}`
`555`	`555`