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 <T> ObservableFuture<T> |
observableFuture()
Create a new
ObservableFuture<T> object: an Observable implementation
implementing Handler<AsyncResult<T>> . |
static <T> ObservableHandler<T> |
observableHandler()
Create a new
ObservableHandler<T> object: an Observable implementation
implementing Handler<T> . |
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, the RxJavaSchedulersHook.getIOScheduler()
uses a blocking scheduler. |
static <T> Handler<AsyncResult<T>> |
toFuture(rx.functions.Action1<T> onNext)
Adapt an item callback as a
Handler<AsyncResult<T>> . |
static <T> Handler<AsyncResult<T>> |
toFuture(rx.functions.Action1<T> onNext,
rx.functions.Action1<Throwable> onError)
Adapt an item callback and an error callback as a
Handler<AsyncResult<T>> . |
static <T> Handler<AsyncResult<T>> |
toFuture(rx.functions.Action1<T> onNext,
rx.functions.Action1<Throwable> onError,
rx.functions.Action0 onComplete)
Adapt an item callback and an error callback as a
Handler<AsyncResult<T>> . |
static <T> Handler<AsyncResult<T>> |
toFuture(rx.Observer<T> observer)
Adapt a
Subscriber as a Handler<AsyncResult<T>>; . |
static <T> Handler<T> |
toHandler(rx.functions.Action1<T> onNext)
Adapt an item callback as a
Handler<T> . |
static <T> Handler<T> |
toHandler(rx.Observer<T> observer)
Adapt a
Subscriber as a Handler<T>; . |
static <T> rx.Observable<T> |
toObservable(ReadStream<T> stream)
Adapts a Vert.x
io.vertx.core.streams.ReadStream to an RxJava Observable . |
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 <T> rx.Observable<T> toObservable(ReadStream<T> stream)
io.vertx.core.streams.ReadStream
to an RxJava Observable
. After
the stream is adapted to an observable, the original stream handlers should not be used anymore
as they will be used by the observable adapter.stream
- the stream to adaptpublic static <T> ObservableFuture<T> observableFuture()
ObservableFuture<T>
object: an Observable
implementation
implementing Handler<AsyncResult<T>>
. When the async result handler completes, the observable
will produce the result and complete immediatly after, when it fails it will signal the error.public static <T> ObservableHandler<T> observableHandler()
ObservableHandler<T>
object: an Observable
implementation
implementing Handler<T>
. When the event handler completes, the observable
will produce the event and complete immediatly after.public static <T> Handler<AsyncResult<T>> toFuture(rx.Observer<T> observer)
Subscriber
as a Handler<AsyncResult<T>>;
.observer
- the subscriber to adaptHandler<AsyncResult<T>>
public static <T> Handler<T> toHandler(rx.Observer<T> observer)
Subscriber
as a Handler<T>;
.observer
- the subscriber to adaptHandler<T>
public static <T> Handler<AsyncResult<T>> toFuture(rx.functions.Action1<T> onNext)
Handler<AsyncResult<T>>
.onNext
- the Action1<T>
you have designed to accept the resolution from the Handler<AsyncResult<T>>
Handler<AsyncResult<T>>
public static <T> Handler<T> toHandler(rx.functions.Action1<T> onNext)
Handler<T>
.onNext
- the Action1<T>
you have designed to accept the resolution from the Handler<T>
Handler<T>
public static <T> Handler<AsyncResult<T>> toFuture(rx.functions.Action1<T> onNext, rx.functions.Action1<Throwable> onError)
Handler<AsyncResult<T>>
.onNext
- the Action1<T>
you have designed to accept the resolution from the Handler<AsyncResult<T>>
onError
- the Action1<Throwable>
you have designed to accept the eventual failure from the Handler<AsyncResult<T>>
Handler<AsyncResult<T>>
public static <T> Handler<AsyncResult<T>> toFuture(rx.functions.Action1<T> onNext, rx.functions.Action1<Throwable> onError, rx.functions.Action0 onComplete)
Handler<AsyncResult<T>>
.onNext
- the Action1<T>
you have designed to accept the resolution from the Handler<AsyncResult<T>>
onError
- the Action1<Throwable>
you have designed to accept the eventual failure from the Handler<AsyncResult<T>>
onComplete
- the Action0
you have designed to accept a completion notification from the Handler<AsyncResult<T>>
Handler<AsyncResult<T>>
public 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 rx.plugins.RxJavaSchedulersHook schedulerHook(Vertx vertx)
Vertx
object, the RxJavaSchedulersHook.getIOScheduler()
uses a blocking scheduler.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.