public class RxHelper extends Object
| Constructor and Description |
|---|
RxHelper() |
| Modifier and Type | Method and Description |
|---|---|
static rx.Scheduler |
blockingScheduler(Vertx vertx)
Create a scheduler for a
Vertx object, actions can be blocking, they are not executed
on Vertx event loop. |
static rx.Scheduler |
scheduler(Vertx vertx)
Create a scheduler for a
Vertx object, actions are executed on the event loop. |
static rx.plugins.RxJavaSchedulersHook |
schedulerHook(Vertx vertx)
Create a scheduler hook for a
Vertx object. |
static <T> rx.Observable.Operator<T,Buffer> |
unmarshaller(Class<T> mappedType)
Returns a json unmarshaller for the specified java type as a
Observable.Operator instance.
The marshaller can be used with the Observable.lift(rx.Observable.Operator) method to transform
a Observable<Buffer> into a Observable<T>.
The unmarshaller buffers the content until onComplete is called, then unmarshalling happens.
Note that the returned observable will emit at most a single object. |
public static rx.plugins.RxJavaSchedulersHook schedulerHook(Vertx vertx)
Vertx object.vertx - the vertx objectpublic static rx.Scheduler scheduler(Vertx vertx)
Vertx object, actions are executed on the event loop.vertx - the vertx objectpublic static rx.Scheduler blockingScheduler(Vertx vertx)
Vertx object, actions can be blocking, they are not executed
on Vertx event loop.vertx - the vertx objectpublic static <T> rx.Observable.Operator<T,Buffer> unmarshaller(Class<T> mappedType)
Observable.Operator instance.
The marshaller can be used with the Observable.lift(rx.Observable.Operator) method to transform
a Observable<Buffer> into a Observable<T>.
The unmarshaller buffers the content until onComplete is called, then unmarshalling happens.
Note that the returned observable will emit at most a single object.mappedType - the type to unmarshallCopyright © 2015. All rights reserved.