Class CompletableHelper

java.lang.Object
io.vertx.rxjava3.CompletableHelper
public class CompletableHelper extends Object
Author:
Julien Viet

  • Constructor Details

    • CompletableHelper

      public CompletableHelper()

  • Method Details

    • nullObserver

      public static CompletableObserver nullObserver()
      Returns:
      a CompletableObserver that does nothing

    • toCompletable

      public static Completable toCompletable(Consumer<Handler<AsyncResult<Void>>> handler)
      Returns a Completable that, when subscribed, uses the provided handler to adapt a callback-based asynchronous method.

      For example: 

      io.vertx.core.Vertx vertx = Vertx.vertx();
// ... later
Completable undeploy = CompletableHelper.toCompletable(handler -> vertx.undeploy(deploymentId, handler));

      This is useful when using RxJava without the Vert.x Rxified API or your own asynchronous methods.

      Parameters:
      handler - the code executed when the returned Completable is subscribed

    • toObserver

      public static <T> CompletableObserver toObserver(Handler<AsyncResult<T>> handler)
      Adapts an Vert.x Handler<AsyncResult<T>> to an RxJava2 SingleObserver.

      The returned observer can be subscribed to an Single.subscribe(SingleObserver).

      Parameters:
      handler - the handler to adapt
      Returns:
      the observer

    • toFuture

      public static <T> Future<Void> toFuture(Completable maybe)
      Adapts an RxJava2 Completable<T> to a Vert.x .

      The completable will be immediately subscribed and the returned future will be updated with the result of the single.

      Parameters:
      maybe - the single to adapt
      Returns:
      the future