public class SingleHelper extends Object
Modifier and Type | Field and Description |
---|---|
static io.reactivex.rxjava3.core.SingleObserver<?> |
NULL_OBSERVER |
Constructor and Description |
---|
SingleHelper() |
Modifier and Type | Method and Description |
---|---|
static <T> io.reactivex.rxjava3.core.SingleObserver<T> |
nullObserver() |
static <T> io.vertx.core.Future<T> |
toFuture(io.reactivex.rxjava3.core.Single<T> single)
Adapts an RxJava2
Single<T> to a Vert.x Future . |
static <T,U> io.vertx.core.Future<U> |
toFuture(io.reactivex.rxjava3.core.Single<T> single,
Function<T,U> adapter)
Like
toFuture(Single) but with an adapter of the result. |
static <T> io.reactivex.rxjava3.core.SingleObserver<T> |
toObserver(io.vertx.core.Handler<io.vertx.core.AsyncResult<T>> handler)
Adapts an Vert.x
Handler<AsyncResult<T>> to an RxJava2 SingleObserver . |
static <T> io.reactivex.rxjava3.core.Single<T> |
toSingle(Consumer<io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>> handler)
Returns a
Single that, when subscribed, uses the provided handler to adapt a callback-based asynchronous method. |
static <T> io.reactivex.rxjava3.core.SingleTransformer<io.vertx.core.buffer.Buffer,T> |
unmarshaller(Class<T> mappedType) |
static <T> io.reactivex.rxjava3.core.SingleTransformer<io.vertx.core.buffer.Buffer,T> |
unmarshaller(Class<T> mappedType,
com.fasterxml.jackson.core.ObjectCodec mapper) |
static <T> io.reactivex.rxjava3.core.SingleTransformer<io.vertx.core.buffer.Buffer,T> |
unmarshaller(com.fasterxml.jackson.core.type.TypeReference<T> mappedTypeRef) |
static <T> io.reactivex.rxjava3.core.SingleTransformer<io.vertx.core.buffer.Buffer,T> |
unmarshaller(com.fasterxml.jackson.core.type.TypeReference<T> mappedTypeRef,
com.fasterxml.jackson.core.ObjectCodec mapper) |
public static final io.reactivex.rxjava3.core.SingleObserver<?> NULL_OBSERVER
public static <T> io.reactivex.rxjava3.core.SingleObserver<T> nullObserver()
SingleObserver
that does nothingpublic static <T> io.reactivex.rxjava3.core.Single<T> toSingle(Consumer<io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>> handler)
Single
that, when subscribed, uses the provided handler
to adapt a callback-based asynchronous method.
For example:
io.vertx.core.Vertx vertx = Vertx.vertx();
Single<String> deploymentId = SingleHelper.toSingle(handler -> vertx.deployVerticle("org.acme.MyVerticle", handler));
This is useful when using RxJava without the Vert.x Rxified API or your own asynchronous methods.
The asynchronous method result must not be null
, as an RxJava 2 Single
does not allow null
values.
handler
- the code executed when the returned Single
is subscribedpublic static <T> io.reactivex.rxjava3.core.SingleObserver<T> toObserver(io.vertx.core.Handler<io.vertx.core.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> io.vertx.core.Future<T> toFuture(io.reactivex.rxjava3.core.Single<T> single)
Single<T>
to a Vert.x Future
.
The single will be immediately subscribed and the returned future will be updated with the result of the single.
single
- the single to adaptpublic static <T,U> io.vertx.core.Future<U> toFuture(io.reactivex.rxjava3.core.Single<T> single, Function<T,U> adapter)
toFuture(Single)
but with an adapter
of the result.public static <T> io.reactivex.rxjava3.core.SingleTransformer<io.vertx.core.buffer.Buffer,T> unmarshaller(Class<T> mappedType)
public static <T> io.reactivex.rxjava3.core.SingleTransformer<io.vertx.core.buffer.Buffer,T> unmarshaller(com.fasterxml.jackson.core.type.TypeReference<T> mappedTypeRef)
public static <T> io.reactivex.rxjava3.core.SingleTransformer<io.vertx.core.buffer.Buffer,T> unmarshaller(Class<T> mappedType, com.fasterxml.jackson.core.ObjectCodec mapper)
public static <T> io.reactivex.rxjava3.core.SingleTransformer<io.vertx.core.buffer.Buffer,T> unmarshaller(com.fasterxml.jackson.core.type.TypeReference<T> mappedTypeRef, com.fasterxml.jackson.core.ObjectCodec mapper)
Copyright © 2022 Eclipse. All rights reserved.