debug: add logs

Author: bevzzz

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

@@ -504,7 +504,9 @@ CompletableFuture<Void> emitEvent(Event event) {
       assert event != Event.EOF : "must not use synthetic EOF event";
       assert !(event instanceof Event.StreamHangup) : "must not use synthetic StreamHangup event";
 
-      return CompletableFuture.runAsync(() -> stream.onNext(event), eventThread);
+      log.debug("emit event {}", event);
+      return CompletableFuture.runAsync(() -> stream.onNext(event), eventThread)
+          .thenAccept(r -> log.debug("ran {}", r));
     }
 
     /** Terminate the server half of the stream abruptly. */
@@ -517,6 +519,7 @@ CompletableFuture<Void> hangup() {
 
     /** Emit events before closing the server half of the stream. */
     void beforeEof(Event... events) {
+      log.debug("add {} events for before-EOF", events.length);
       this.pendingEvents.addAll(Arrays.asList(events));
     }
 
@@ -527,6 +530,8 @@ void beforeEof(Event... events) {
      *           stream is being hung up by the client, not by us.
      */
     CompletableFuture<Void> eof(boolean ok) {
+      log.debug("emit EOF, ok={}", ok);
+      log.debug("have {} events pre-hooked", this.pendingEvents.size());
       CompletableFuture<?> await = ok
           ? CompletableFuture.allOf(pendingEvents.stream().map(this::emitEvent).toArray(CompletableFuture[]::new))
           : CompletableFuture.completedFuture(null);