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 © 2021 Eclipse. All rights reserved.