Skip to content

Commit 9bee828

Browse files
committed
fix(batch): force the results to be applied before closing the context
1 parent 0168053 commit 9bee828

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
@@ -180,7 +180,7 @@ public void test_sendOneBatch() throws Exception {
180180
Assertions.assertThat(tasks)
181181
.extracting(TaskHandle::isAcked).allMatch(CompletableFuture::isDone);
182182

183-
out.beforeEof(new Event.Results(received, Collections.emptyMap()));
183+
out.emitEvent(new Event.Results(received, Collections.emptyMap())).get();
184184

185185
// Since MockServer runs in the same thread as this test,
186186
// the context will be updated before the last emitEvent returns.

0 commit comments

Comments
 (0)