public class MaybeHelper extends Object
Constructor and Description |
---|
MaybeHelper() |
Modifier and Type | Method and Description |
---|---|
static <T> io.reactivex.Maybe<T> |
toMaybe(Consumer<io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>> handler)
Returns a
Maybe that, when subscribed, uses the provided handler to adapt a callback-based asynchronous method. |
static <T> io.reactivex.MaybeObserver<T> |
toObserver(io.vertx.core.Handler<io.vertx.core.AsyncResult<T>> handler)
Adapts an Vert.x
Handler<AsyncResult<T>> to an RxJava2 MaybeObserver . |
static <T> io.reactivex.MaybeTransformer<io.vertx.core.buffer.Buffer,T> |
unmarshaller(Class<T> mappedType) |
static <T> io.reactivex.MaybeTransformer<io.vertx.core.buffer.Buffer,T> |
unmarshaller(Class<T> mappedType,
com.fasterxml.jackson.databind.ObjectMapper mapper) |
static <T> io.reactivex.MaybeTransformer<io.vertx.core.buffer.Buffer,T> |
unmarshaller(com.fasterxml.jackson.core.type.TypeReference<T> mappedTypeRef) |
static <T> io.reactivex.MaybeTransformer<io.vertx.core.buffer.Buffer,T> |
unmarshaller(com.fasterxml.jackson.core.type.TypeReference<T> mappedTypeRef,
com.fasterxml.jackson.databind.ObjectMapper mapper) |
public static <T> io.reactivex.Maybe<T> toMaybe(Consumer<io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>> handler)
Maybe
that, when subscribed, uses the provided handler
to adapt a callback-based asynchronous method.
For example:
io.vertx.core.Vertx vertx = Vertx.vertx();
Maybe<String> blockingMethodResult = MaybeHelper.toMaybe(handler -> vertx.<String>executeBlocking(fut -> fut.complete(invokeBlocking()), 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 Maybe
is subscribedpublic static <T> io.reactivex.MaybeObserver<T> toObserver(io.vertx.core.Handler<io.vertx.core.AsyncResult<T>> handler)
Handler<AsyncResult<T>>
to an RxJava2 MaybeObserver
.
The returned observer can be subscribed to an Maybe.subscribe(MaybeObserver)
.
handler
- the handler to adaptpublic static <T> io.reactivex.MaybeTransformer<io.vertx.core.buffer.Buffer,T> unmarshaller(Class<T> mappedType)
public static <T> io.reactivex.MaybeTransformer<io.vertx.core.buffer.Buffer,T> unmarshaller(com.fasterxml.jackson.core.type.TypeReference<T> mappedTypeRef)
public static <T> io.reactivex.MaybeTransformer<io.vertx.core.buffer.Buffer,T> unmarshaller(Class<T> mappedType, com.fasterxml.jackson.databind.ObjectMapper mapper)
public static <T> io.reactivex.MaybeTransformer<io.vertx.core.buffer.Buffer,T> unmarshaller(com.fasterxml.jackson.core.type.TypeReference<T> mappedTypeRef, com.fasterxml.jackson.databind.ObjectMapper mapper)
Copyright © 2020 Eclipse. All rights reserved.