public class CompletableHelper extends Object
| Constructor and Description |
|---|
CompletableHelper() |
| Modifier and Type | Method and Description |
|---|---|
static CompletableObserver |
nullObserver() |
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)
|
static <T> CompletableObserver |
toObserver(Handler<AsyncResult<T>> handler)
Adapts an Vert.x
Handler<AsyncResult<T>> to an RxJava2 SingleObserver. |
public static CompletableObserver nullObserver()
CompletableObserver that does nothingpublic static Completable toCompletable(java.util.function.Consumer<Handler<AsyncResult<Void>>> handler)
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.
handler - the code executed when the returned Completable is subscribedpublic static <T> CompletableObserver toObserver(Handler<AsyncResult<T>> handler)
Handler<AsyncResult<T>> to an RxJava2 SingleObserver.
The returned observer can be subscribed to an Single.subscribe(SingleObserver).
handler - the handler to adaptpublic static <T> Future<Void> toFuture(Completable maybe)
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.
maybe - the single to adaptCopyright © 2026 Eclipse. All rights reserved.