open class RxHelper
A set of helpers for RxJava and Vert.x.
Author
Julien Viet
RxHelper()
A set of helpers for RxJava and Vert.x. |
open static fun blockingScheduler(vertx: Vertx): Scheduler
Create a scheduler for a Vertx object, actions can be blocking, they are not executed on Vertx event loop. |
|
open static fun deployVerticle(vertx: Vertx, verticle: Verticle): Observable<String>
Deploy a verticle you have created yourself, using an RxJava vertx instance. open static fun deployVerticle(vertx: Vertx, verticle: Verticle, options: DeploymentOptions): Observable<String>
Like |
|
open static fun get(client: HttpClient, requestURI: String): Observable<HttpClientResponse>open static fun get(client: HttpClient, host: String, requestURI: String): Observable<HttpClientResponse>open static fun get(client: HttpClient, port: Int, host: String, requestURI: String): Observable<HttpClientResponse>open static fun get(client: HttpClient, port: Int, host: String, requestURI: String, headers: MultiMap): Observable<HttpClientResponse>
Returns an This is different from the |
|
open static fun scheduler(vertx: Vertx): Scheduler
Create a scheduler for a Vertx object, actions are executed on the event loop of the current context. open static fun scheduler(executor: WorkerExecutor): Scheduler
Create a scheduler for a WorkerExecutor object, actions are executed on the threads of this executor. open static fun scheduler(context: Context): Scheduler
Create a scheduler for a Context, actions are executed on the event loop of this context. |
|
open static fun schedulerHook(vertx: Vertx): RxJavaSchedulersHook
Create a scheduler hook for a io.vertx.rxjava.core.Vertx object. open static fun schedulerHook(context: Context): RxJavaSchedulersHook
Create a scheduler hook for a io.vertx.rxjava.core.Context object. |
|
open static fun <T : Any> unmarshaller(mappedType: Class<T>): Operator<T, Buffer>
Returns a json unmarshaller for the specified java type as a rx.Observable.Operator instance. The marshaller can be used with the |