Skip to content

Commit 202572c

Browse files
committed
test(batch): acks data synchronously
1 parent 9e3cf56 commit 202572c

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

‎src/test/java/io/weaviate/client6/v1/api/collections/batch/BatchContextTest.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -502,7 +502,7 @@ public void test_startAfterClose() throws Exception {
502502
*/
503503
private List<String> recvDataAndAck() throws InterruptedException {
504504
List<String> received = recvData();
505-
out.emitEventAsync(new Event.Acks(received));
505+
out.emitEvent(new Event.Acks(received));
506506
return received;
507507
}
508508

0 commit comments

Comments
 (0)