Package | Description |
---|---|
io.vertx.rxjava.core | |
io.vertx.rxjava.ext.unit |
Modifier and Type | Method and Description |
---|---|
static <T> Future<T> |
Future.failedFuture(String failureMessage)
Create a failed future with the specified failure message.
|
static <T> Future<T> |
Future.future()
Create a future that hasn't completed yet
|
static <T> Future<T> |
Future.newInstance(Future arg) |
static <T> Future<T> |
Future.succeededFuture()
Create a succeeded future with a null result
|
static <T> Future<T> |
Future.succeededFuture(T result)
Created a succeeded future with the specified result.
|
Modifier and Type | Method and Description |
---|---|
<T> void |
Vertx.executeBlocking(Handler<Future<T>> blockingCodeHandler,
Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> rx.Observable<T> |
Vertx.executeBlockingObservable(Handler<Future<T>> blockingCodeHandler)
Safely execute some blocking code.
|
Modifier and Type | Method and Description |
---|---|
void |
TestCompletion.resolve(Future future)
Completes the future when all test cases of the test suite passes, otherwise fails it.
|
Copyright © 2015. All Rights Reserved.