Interface AsyncCallback


  • public interface AsyncCallback
    Async io completion abstraction used by the native mqtt layer. We moved to using futures directly but that might have been a mistake and we should consider moving back to this for our other async operations that cross the managed/native boundary
    • Method Detail

      • wrapFuture

        static <T> AsyncCallback wrapFuture​(java.util.concurrent.CompletableFuture<T> future,
                                            T value)
      • onSuccess

        void onSuccess()
      • onSuccess

        void onSuccess​(java.lang.Object value)
      • onFailure

        void onFailure​(java.lang.Throwable reason)