Create Uni off of Elastic Async, Await issues

[m-dot-exe]

Hello, so I created a Uni using the RestHighLevelClients' IndexAsync function and have no problem invoking the logic, callbacks are successfully invoked -

Uni.createFrom().item(restHighLevelClient.updateAsync(updateRequest, DEFAULT, new ActionListener<>() {
 //  onResponse callback
  //  onFailure callback 
      })).onItem()
                .invoke(() -> someLogic())); 

The issue I'm experiencing is trying to use await().indefinitely() on my integration tests - it doesn't and as a result, the data I'd need for my assert statements also fail. Naturally using Thread.sleep() gets the job done but of course I'd much prefer to use the Uni API. Currently, my company has approved v 0.14.0 - is that an issue that was fixed at a later version or am I incorrectly using the createFrom() method?

[Ladicek]

I'm no Elasticsearch expert, but RestHighLevelClient.updateAsync looks like a plain old callback-based API, so the easiest way to adapt that to Uni probably is:

Uni.createFrom().emitter(em -> {
    Cancellable token = restHighLevelClient.updateAsync(updateRequest, DEFAULT, new ActionListener<>() {
        void onResponse(Response response) {
            em.complete(response);
        }

        void onFailure(Exception e) {
            em.fail(e);
        }
    }
    em.onTermination(() -> token.cancel());
});

On that, you can call your .onItem().invoke(() -> someLogic())).

That said, if this is in Quarkus or Vert.x context, there's Vert.x binding for Elasticsearch high-level client (https://reactiverse.io/elasticsearch-client/) and @jponge is working on a Mutiny binding for that. That would probably be best -- once it exists :-)

[m-dot-exe]

Perfect - that did it! Thank you very much!

[jponge]

There's work in progress for a new release of reactiverse/elasticsearch-client#11 with Mutiny bindings.