debug: schedule events manually

Author: bevzzz

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

@@ -187,6 +187,7 @@ public void test_sendOneBatch() throws Exception {
     Assertions.assertThat(tasks)
         .extracting(TaskHandle::isAcked).allMatch(CompletableFuture::isDone);
 
+    out.pendingEvents.add(new Event.Results(received, Collections.emptyMap()));
     out.beforeEof(new Event.Results(received, Collections.emptyMap()));
 
     // Since MockServer runs in the same thread as this test,
@@ -506,7 +507,7 @@ CompletableFuture<Void> emitEvent(Event event) {
 
       log.debug("emit event {}", event);
       return CompletableFuture.runAsync(() -> stream.onNext(event), eventThread)
-          .thenAccept(r -> log.debug("ran {}", r));
+          .thenRun(() -> log.debug("ran {}", event));
     }
 
     /** Terminate the server half of the stream abruptly. */