io.vertx.reactivex

Class CompletableHelper

java.lang.Object

io.vertx.reactivex.CompletableHelper

public class CompletableHelper
extends Object

Author:

Julien Viet

Constructor Summary

Constructors

Constructor and Description
CompletableHelper()

Method Summary

Modifier and Type	Method and Description
static Completable	toCompletable(java.util.function.Consumer<Handler<AsyncResult<Void>>> handler) Returns a Completable that, when subscribed, uses the provided handler to adapt a callback-based asynchronous method.
static <T> Future<Void>	toFuture(Completable maybe) Adapts an RxJava2 Completable<T> to a Vert.x .
static <T> CompletableObserver	toObserver(Handler<AsyncResult<T>> handler) Adapts an Vert.x Handler<AsyncResult<T>> to an RxJava2 SingleObserver.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CompletableHelper

public CompletableHelper()

Method Detail

toCompletable

public static Completable toCompletable(java.util.function.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