Emitter send and wait

SendAndWait.java

  private final Emitter<MyObject> emitter;  
  
  @Override
  public void sendingAndWait(final MyObject payload) {
    final var future = new CompletableFuture<Void>();
    final var message = Message.of(payload,
            () -> success(future),
            (reason) -> failure(future, reason));
    emitter.send(message);
    future.toCompletableFuture().join();
  }

  private CompletableFuture<Void> success(final CompletableFuture<Void> future) {
    future.complete(null);
    return CompletableFuture.completedFuture(null);
  }

  private CompletableFuture<Void> failure(final CompletableFuture<Void> future,
                                          final Throwable reason) {
    future.completeExceptionally(reason);
    return CompletableFuture.completedFuture(null);
  }