| Modifier and Type | Method and Description |
|---|---|
<T> Future<T> |
CircuitBreaker.execute(Handler<Promise<T>> command)
Same as
CircuitBreaker.executeWithFallback(Handler, Function) but using the circuit breaker default fallback. |
<T> Future<T> |
CircuitBreaker.executeWithFallback(Handler<Promise<T>> command,
java.util.function.Function<Throwable,T> fallback)
Executes the given operation with the circuit breaker control.
|
| Modifier and Type | Method and Description |
|---|---|
static Future<JsonObject> |
ConfigRetriever.getConfigAsFuture(ConfigRetriever retriever)
Same as
ConfigRetriever.getConfig(Handler), but returning a Future object. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
CompositeFuture
The composite future wraps a list of
futures, it is useful when several futures
needs to be coordinated. |
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
Vertx.close()
Stop the the Vertx instance and release any resources held by it.
|
static Future<Vertx> |
Vertx.clusteredVertx(VertxOptions options)
Same as
Vertx.clusteredVertx(VertxOptions, Handler) but with an handler called when the operation completes |
default <U> Future<U> |
Future.compose(java.util.function.Function<T,Future<U>> mapper)
Compose this future with a
mapper function. |
Future<String> |
Vertx.deployVerticle(Class<? extends Verticle> verticleClass,
DeploymentOptions options)
Like
Vertx.deployVerticle(Verticle, DeploymentOptions) but Verticle instance is created by invoking the
default constructor of verticleClass. |
Future<String> |
Vertx.deployVerticle(String name)
Deploy a verticle instance given a name.
|
Future<String> |
Vertx.deployVerticle(String name,
DeploymentOptions options)
Like
Vertx.deployVerticle(Verticle) but DeploymentOptions are provided to configure the
deployment. |
Future<String> |
Vertx.deployVerticle(java.util.function.Supplier<Verticle> verticleSupplier,
DeploymentOptions options)
Like
Vertx.deployVerticle(Verticle, DeploymentOptions) but Verticle instance is created by invoking the
verticleSupplier. |
Future<String> |
Vertx.deployVerticle(Verticle verticle)
Deploy a verticle instance that you have created yourself.
|
Future<String> |
Vertx.deployVerticle(Verticle verticle,
DeploymentOptions options)
Like
Vertx.deployVerticle(Verticle) but DeploymentOptions are provided to configure the
deployment. |
default <T> Future<T> |
Context.executeBlocking(Handler<Promise<T>> blockingCodeHandler)
Same as
Context.executeBlocking(Handler, Handler) but with an handler called when the operation completes |
default <T> Future<T> |
Vertx.executeBlocking(Handler<Promise<T>> blockingCodeHandler)
Same as
Vertx.executeBlocking(Handler, Handler) but with an handler called when the operation completes |
default <T> Future<T> |
WorkerExecutor.executeBlocking(Handler<Promise<T>> blockingCodeHandler)
Like
WorkerExecutor.executeBlocking(Handler, boolean, Handler) called with ordered = true. |
default <T> Future<T> |
Context.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered)
Same as
Context.executeBlocking(Handler, boolean, Handler) but with an handler called when the operation completes |
default <T> Future<T> |
Vertx.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered)
Same as
Vertx.executeBlocking(Handler, boolean, Handler) but with an handler called when the operation completes |
default <T> Future<T> |
WorkerExecutor.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered)
Same as
WorkerExecutor.executeBlocking(Handler, boolean, Handler) but with an handler called when the operation completes |
static <T> Future<T> |
Future.failedFuture(String failureMessage)
Create a failed future with the specified failure message.
|
static <T> Future<T> |
Future.failedFuture(Throwable t)
Create a failed future with the specified failure cause.
|
Future<T> |
Promise.future() |
static <T> Future<T> |
Future.future(Handler<Promise<T>> handler)
Create a future that hasn't completed yet and that is passed to the
handler before it is returned. |
default <U> Future<U> |
Future.map(java.util.function.Function<T,U> mapper)
Apply a
mapper function on this future. |
default <V> Future<V> |
Future.map(V value)
Map the result of a future to a specific
value. |
default <V> Future<V> |
Future.mapEmpty()
Map the result of a future to
null. |
default Future<T> |
Future.otherwise(java.util.function.Function<Throwable,T> mapper)
Apply a
mapper function on this future. |
default Future<T> |
Future.otherwise(T value)
Map the failure of a future to a specific
value. |
default Future<T> |
Future.otherwiseEmpty()
Map the failure of a future to
null. |
default Future<T> |
Future.recover(java.util.function.Function<Throwable,Future<T>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
Future<T> |
Future.setHandler(Handler<AsyncResult<T>> handler)
Set a handler for the result.
|
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.
|
Future<Void> |
Vertx.undeploy(String deploymentID)
Undeploy a verticle deployment.
|
| Modifier and Type | Method and Description |
|---|---|
static <T1,T2> CompositeFuture |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2)
Return a composite future, succeeded when all futures are succeeded, failed when any future is failed.
|
static <T1,T2> CompositeFuture |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2)
Return a composite future, succeeded when all futures are succeeded, failed when any future is failed.
|
static <T1,T2,T3> CompositeFuture |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.all(Future, Future) but with 3 futures. |
static <T1,T2,T3> CompositeFuture |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.all(Future, Future) but with 3 futures. |
static <T1,T2,T3> CompositeFuture |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.all(Future, Future) but with 3 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.all(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.all(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.all(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.all(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.all(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.all(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.all(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.all(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.all(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.all(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.all(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.all(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.all(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.all(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.all(Future, Future) but with 6 futures. |
static <T1,T2> CompositeFuture |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2)
Return a composite future, succeeded when any futures is succeeded, failed when all futures are failed.
|
static <T1,T2> CompositeFuture |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2)
Return a composite future, succeeded when any futures is succeeded, failed when all futures are failed.
|
static <T1,T2,T3> CompositeFuture |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.any(Future, Future) but with 3 futures. |
static <T1,T2,T3> CompositeFuture |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.any(Future, Future) but with 3 futures. |
static <T1,T2,T3> CompositeFuture |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.any(Future, Future) but with 3 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.any(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.any(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.any(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.any(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.any(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.any(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.any(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.any(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.any(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.any(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.any(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.any(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.any(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.any(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.any(Future, Future) but with 6 futures. |
static <T1,T2> CompositeFuture |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2)
Return a composite future, succeeded when all futures are succeeded, failed when any future is failed.
|
static <T1,T2> CompositeFuture |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2)
Return a composite future, succeeded when all futures are succeeded, failed when any future is failed.
|
static <T1,T2,T3> CompositeFuture |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.join(Future, Future) but with 3 futures. |
static <T1,T2,T3> CompositeFuture |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.join(Future, Future) but with 3 futures. |
static <T1,T2,T3> CompositeFuture |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.join(Future, Future) but with 3 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.join(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.join(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.join(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.join(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.join(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.join(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.join(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.join(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.join(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.join(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.join(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.join(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.join(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.join(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.join(Future, Future) but with 6 futures. |
| Modifier and Type | Method and Description |
|---|---|
static CompositeFuture |
CompositeFuture.all(List<Future> futures)
Like
CompositeFuture.all(Future, Future) but with a list of futures. |
static CompositeFuture |
CompositeFuture.any(List<Future> futures)
Like
CompositeFuture.any(Future, Future) but with a list of futures. |
default <U> Future<U> |
Future.compose(java.util.function.Function<T,Future<U>> mapper)
Compose this future with a
mapper function. |
static CompositeFuture |
CompositeFuture.join(List<Future> futures)
Like
CompositeFuture.join(Future, Future) but with a list of futures. |
default Future<T> |
Future.recover(java.util.function.Function<Throwable,Future<T>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
| Modifier and Type | Method and Description |
|---|---|
default Future<Void> |
DatagramSocket.blockMulticastGroup(String multicastAddress,
String sourceToBlock)
Like
DatagramSocket.blockMulticastGroup(String, String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.blockMulticastGroup(String multicastAddress,
String networkInterface,
String sourceToBlock)
Like
DatagramSocket.blockMulticastGroup(String, String, String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.close()
Closes the
DatagramSocket. |
default Future<DatagramSocket> |
DatagramSocket.listen(int port,
String host)
Like
DatagramSocket.listen(int, String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.listenMulticastGroup(String multicastAddress)
Like
DatagramSocket.listenMulticastGroup(String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.listenMulticastGroup(String multicastAddress,
String networkInterface,
String source)
Like
DatagramSocket.listenMulticastGroup(String, String, String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.send(Buffer packet,
int port,
String host)
Like
DatagramSocket.send(Buffer, int, String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.send(String str,
int port,
String host)
Like
DatagramSocket.send(String, int, String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.send(String str,
String enc,
int port,
String host)
Like
DatagramSocket.send(String, String, int, String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.unlistenMulticastGroup(String multicastAddress)
Like
DatagramSocket.unlistenMulticastGroup(String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.unlistenMulticastGroup(String multicastAddress,
String networkInterface,
String source)
Like
DatagramSocket.unlistenMulticastGroup(String, String, String, Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Method and Description |
|---|---|
default Future<String> |
DnsClient.lookup(String name)
Like
DnsClient.lookup(String, Handler) but returns a Future of the asynchronous result |
default Future<String> |
DnsClient.lookup4(String name)
Like
DnsClient.lookup4(String, Handler) but returns a Future of the asynchronous result |
default Future<String> |
DnsClient.lookup6(String name)
Like
DnsClient.lookup6(String, Handler) but returns a Future of the asynchronous result |
default Future<List<String>> |
DnsClient.resolveA(String name)
Like
DnsClient.resolveA(String, Handler) but returns a Future of the asynchronous result |
default Future<List<String>> |
DnsClient.resolveAAAA(String name)
Like
DnsClient.resolveAAAA(String, Handler) but returns a Future of the asynchronous result |
default Future<List<String>> |
DnsClient.resolveCNAME(String name)
Like
DnsClient.resolveCNAME(String, Handler) but returns a Future of the asynchronous result |
default Future<List<MxRecord>> |
DnsClient.resolveMX(String name)
Like
DnsClient.resolveMX(String, Handler) but returns a Future of the asynchronous result |
default Future<List<String>> |
DnsClient.resolveNS(String name)
Like
DnsClient.resolveNS(String, Handler) but returns a Future of the asynchronous result |
default Future<String> |
DnsClient.resolvePTR(String name)
Like
DnsClient.resolvePTR(String, Handler) but returns a Future of the asynchronous result |
default Future<List<SrvRecord>> |
DnsClient.resolveSRV(String name)
Like
DnsClient.resolveSRV(String, Handler) but returns a Future of the asynchronous result |
default Future<List<String>> |
DnsClient.resolveTXT(String name)
Like
DnsClient.resolveTXT(String, Handler) but returns a Future of the asynchronous result |
default Future<String> |
DnsClient.reverseLookup(String ipaddress)
Like
DnsClient.reverseLookup(String, Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
MessageProducer.close()
Closes the producer, this method should be called when the message producer is not used anymore.
|
Future<Void> |
MessageProducer.end()
Closes the producer, calls
MessageProducer.close() |
default <R> Future<Message<R>> |
Message.replyAndRequest(Object message)
Like
Message.replyAndRequest(Object, Handler) but returns a Future of the asynchronous result |
default <R> Future<Message<R>> |
Message.replyAndRequest(Object message,
DeliveryOptions options)
Like
Message.replyAndRequest(Object, DeliveryOptions, Handler) but returns a Future of the asynchronous result |
default <T> Future<Message<T>> |
EventBus.request(String address,
Object message)
Like
EventBus.request(String, Object, Handler) but returns a Future of the asynchronous result |
default <T> Future<Message<T>> |
EventBus.request(String address,
Object message,
DeliveryOptions options)
Like
EventBus.request(String, Object, DeliveryOptions, Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
FileSystem.chmod(String path,
String perms)
Like
FileSystem.chmod(String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.chmodRecursive(String path,
String perms,
String dirPerms)
Like
FileSystem.chmodRecursive(String, String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.chown(String path,
String user,
String group)
Like
FileSystem.chown(String, String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
AsyncFile.close()
Close the file.
|
Future<Void> |
FileSystem.copy(String from,
String to)
Like
FileSystem.copy(String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.copy(String from,
String to,
CopyOptions options)
Like
FileSystem.copy(String, String, CopyOptions, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.copyRecursive(String from,
String to,
boolean recursive)
Like
FileSystem.copyRecursive(String, String, boolean, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.createFile(String path)
Like
FileSystem.createFile(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.createFile(String path,
String perms)
Like
FileSystem.createFile(String, String, Handler) but returns a Future of the asynchronous result |
Future<String> |
FileSystem.createTempDirectory(String prefix)
Like
FileSystem.createTempDirectory(String, Handler) but returns a Future of the asynchronous result |
Future<String> |
FileSystem.createTempDirectory(String prefix,
String perms)
Like
FileSystem.createTempDirectory(String, String, Handler) but returns a Future of the asynchronous result |
Future<String> |
FileSystem.createTempDirectory(String dir,
String prefix,
String perms)
Like
FileSystem.createTempDirectory(String, String, String, Handler) but returns a Future of the asynchronous result |
Future<String> |
FileSystem.createTempFile(String prefix,
String suffix)
Like
FileSystem.createTempFile(String, String, Handler) but returns a Future of the asynchronous result |
Future<String> |
FileSystem.createTempFile(String prefix,
String suffix,
String perms)
Like
FileSystem.createTempFile(String, String, String, Handler) but returns a Future of the asynchronous result |
Future<String> |
FileSystem.createTempFile(String dir,
String prefix,
String suffix,
String perms)
Like
FileSystem.createTempFile(String, String, String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.delete(String path)
Like
FileSystem.delete(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.deleteRecursive(String path,
boolean recursive)
Like
FileSystem.deleteRecursive(String, boolean, Handler) but returns a Future of the asynchronous result |
Future<Boolean> |
FileSystem.exists(String path)
Like
FileSystem.exists(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
AsyncFile.flush()
Flush any writes made to this file to underlying persistent storage.
|
Future<FileSystemProps> |
FileSystem.fsProps(String path)
Like
FileSystem.fsProps(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.link(String link,
String existing)
Like
FileSystem.link(String, String, Handler) but returns a Future of the asynchronous result |
Future<FileProps> |
FileSystem.lprops(String path)
Like
FileSystem.lprops(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.mkdir(String path)
Like
FileSystem.mkdir(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.mkdir(String path,
String perms)
Like
FileSystem.mkdir(String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.mkdirs(String path)
Like
FileSystem.mkdirs(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.mkdirs(String path,
String perms)
Like
FileSystem.mkdirs(String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.move(String from,
String to)
Like
FileSystem.move(String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.move(String from,
String to,
CopyOptions options)
Like
FileSystem.move(String, String, CopyOptions, Handler) but returns a Future of the asynchronous result |
Future<AsyncFile> |
FileSystem.open(String path,
OpenOptions options)
Like
FileSystem.open(String, OpenOptions, Handler) but returns a Future of the asynchronous result |
Future<FileProps> |
FileSystem.props(String path)
Like
FileSystem.props(String, Handler) but returns a Future of the asynchronous result |
Future<Buffer> |
AsyncFile.read(Buffer buffer,
int offset,
long position,
int length)
Like
AsyncFile.read(Buffer, int, long, int, Handler) but returns a Future of the asynchronous result |
Future<List<String>> |
FileSystem.readDir(String path)
Like
FileSystem.readDir(String, Handler) but returns a Future of the asynchronous result |
Future<List<String>> |
FileSystem.readDir(String path,
String filter)
Like
FileSystem.readDir(String, Handler) but returns a Future of the asynchronous result |
Future<Buffer> |
FileSystem.readFile(String path)
Like
FileSystem.readFile(String, Handler) but returns a Future of the asynchronous result |
Future<String> |
FileSystem.readSymlink(String link)
Like
FileSystem.readSymlink(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.symlink(String link,
String existing)
Like
FileSystem.symlink(String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.truncate(String path,
long len)
Like
FileSystem.truncate(String, long, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.unlink(String link)
Like
FileSystem.unlink(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
AsyncFile.write(Buffer buffer,
long position)
Like
AsyncFile.write(Buffer, long, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.writeFile(String path,
Buffer data)
Like
FileSystem.writeFile(String, Buffer, Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Interface and Description |
|---|---|
interface |
HttpClientRequest
Represents a client-side HTTP request.
|
| Modifier and Type | Method and Description |
|---|---|
Future<Buffer> |
HttpClientResponse.body()
Convenience method for receiving the entire request body in one piece.
|
Future<Buffer> |
HttpServerRequest.body()
Convenience method for receiving the entire request body in one piece.
|
Future<Void> |
ServerWebSocket.close()
Close the WebSocket sending the default close frame.
|
Future<Void> |
HttpServer.close()
Close the server.
|
Future<Void> |
HttpConnection.close()
Close the connection and all the currently active streams.
|
Future<Void> |
WebSocketBase.close()
Close the WebSocket sending the default close frame.
|
Future<Void> |
WebSocketBase.close(short statusCode)
Close the WebSocket sending a close frame with specified status code.
|
Future<Void> |
WebSocketBase.close(short statusCode,
String reason)
Close sending a close frame with specified status code and reason.
|
Future<Void> |
HttpServerResponse.end()
Ends the response.
|
Future<Void> |
HttpClientRequest.end()
Ends the request.
|
Future<Void> |
WebSocketBase.end()
Ends the stream.
|
Future<Void> |
HttpServerResponse.end(Buffer chunk)
Same as
HttpServerResponse.end() but writes some data to the response body before ending. |
Future<Void> |
HttpClientRequest.end(Buffer chunk)
Same as
HttpClientRequest.end() but writes some data to the request body before ending. |
Future<Void> |
HttpServerResponse.end(String chunk)
Same as
HttpServerResponse.end(Buffer) but writes a String in UTF-8 encoding before ending the response. |
Future<Void> |
HttpClientRequest.end(String chunk)
Same as
HttpClientRequest.end(Buffer) but writes a String in UTF-8 encoding |
Future<Void> |
HttpServerResponse.end(String chunk,
String enc)
Same as
HttpServerResponse.end(Buffer) but writes a String with the specified encoding before ending the response. |
Future<Void> |
HttpClientRequest.end(String chunk,
String enc)
Same as
HttpClientRequest.end(Buffer) but writes a String with the specified encoding |
default Future<HttpClientResponse> |
HttpClient.getNow(int port,
String host,
String requestURI)
Like
HttpClient.getNow(int, String, String, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.getNow(RequestOptions options)
Like
HttpClient.getNow(RequestOptions, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.getNow(String requestURI)
Like
HttpClient.getNow(String, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.getNow(String host,
String requestURI)
Like
HttpClient.getNow(String, String, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.headNow(int port,
String host,
String requestURI)
Like
HttpClient.headNow(int, String, String, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.headNow(RequestOptions options)
Like
HttpClient.headNow(RequestOptions, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.headNow(String requestURI)
Like
HttpClient.headNow(String, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.headNow(String host,
String requestURI)
Like
HttpClient.headNow(String, String, Handler) but returns a Future of the asynchronous result |
Future<HttpServer> |
HttpServer.listen()
Tell the server to start listening.
|
Future<HttpServer> |
HttpServer.listen(int port)
Like
HttpServer.listen(int, String) but the server will listen on host "0.0.0.0" and port specified here ignoring
any value in the HttpServerOptions that was used when creating the server. |
Future<HttpServer> |
HttpServer.listen(int port,
String host)
Tell the server to start listening.
|
Future<HttpServer> |
HttpServer.listen(SocketAddress address)
Like
HttpServer.listen(SocketAddress, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.optionsNow(int port,
String host,
String requestURI)
Like
HttpClient.optionsNow(int, String, String, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.optionsNow(RequestOptions options)
Like
HttpClient.optionsNow(RequestOptions, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.optionsNow(String requestURI)
Like
HttpClient.optionsNow(String, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.optionsNow(String host,
String requestURI)
Like
HttpClient.optionsNow(String, String, Handler) but returns a Future of the asynchronous result |
Future<Buffer> |
HttpConnection.ping(Buffer data)
Same as
HttpConnection.ping(Buffer, Handler) but returns a Future of the asynchronous result |
default Future<HttpServerResponse> |
HttpServerResponse.push(HttpMethod method,
String path)
Same as
HttpServerResponse.push(HttpMethod, String, Handler) but with an handler called when the operation completes |
default Future<HttpServerResponse> |
HttpServerResponse.push(HttpMethod method,
String path,
MultiMap headers)
Same as
HttpServerResponse.push(HttpMethod, String, MultiMap, Handler) but with an handler called when the operation completes |
default Future<HttpServerResponse> |
HttpServerResponse.push(HttpMethod method,
String host,
String path)
Same as
HttpServerResponse.push(HttpMethod, String, String, Handler) but with an handler called when the operation completes |
default Future<HttpServerResponse> |
HttpServerResponse.push(HttpMethod method,
String host,
String path,
MultiMap headers)
Same as
HttpServerResponse.push(HttpMethod, String, String, MultiMap, Handler) but with an handler called when the operation completes |
default Future<Void> |
HttpServerResponse.sendFile(String filename)
Same as
HttpServerResponse.sendFile(String, long) using offset @code{0} which means starting from the beginning of the file. |
default Future<Void> |
HttpServerResponse.sendFile(String filename,
long offset)
Same as
HttpServerResponse.sendFile(String, long, long) using length @code{Long.MAX_VALUE} which means until the end of the
file. |
default Future<Void> |
HttpServerResponse.sendFile(String filename,
long offset,
long length)
Ask the OS to stream a file as specified by
filename directly
from disk to the outgoing connection, bypassing userspace altogether
(where supported by the underlying operating system. |
Future<Void> |
HttpConnection.updateSettings(Http2Settings settings)
Send to the remote endpoint an update of the server settings.
|
Future<WebSocket> |
HttpClient.webSocket(int port,
String host,
String requestURI)
Like
HttpClient.webSocket(int, String, String, Handler) but returns a Future of the asynchronous result |
Future<WebSocket> |
HttpClient.webSocket(String requestURI)
Like
HttpClient.webSocket(String, Handler) but returns a Future of the asynchronous result |
Future<WebSocket> |
HttpClient.webSocket(String host,
String requestURI)
Like
HttpClient.webSocket(String, String, Handler) but returns a Future of the asynchronous result |
Future<WebSocket> |
HttpClient.webSocket(WebSocketConnectOptions options)
Like
HttpClient.webSocket(WebSocketConnectOptions, Handler) but returns a Future of the asynchronous result |
Future<WebSocket> |
HttpClient.webSocketAbs(String url,
MultiMap headers,
WebsocketVersion version,
List<String> subProtocols)
Like
HttpClient.webSocketAbs(String, MultiMap, WebsocketVersion, List, Handler) but returns a Future of the asynchronous result |
Future<Void> |
HttpServerResponse.write(String chunk)
Write a
String to the response body, encoded in UTF-8. |
Future<Void> |
HttpClientRequest.write(String chunk)
Write a
String to the request body, encoded as UTF-8. |
Future<Void> |
HttpServerResponse.write(String chunk,
String enc)
Write a
String to the response body, encoded using the encoding enc. |
Future<Void> |
HttpClientRequest.write(String chunk,
String enc)
Write a
String to the request body, encoded using the encoding enc. |
Future<Void> |
WebSocketBase.writeBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.
|
Future<Void> |
WebSocketBase.writeFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connection
|
Future<Void> |
WebSocketBase.writeFinalTextFrame(String text)
Write a final WebSocket text frame to the connection
|
Future<Void> |
WebSocketBase.writeFrame(WebSocketFrame frame)
Write a WebSocket frame to the connection
|
Future<Void> |
WebSocketBase.writeTextMessage(String text)
Writes a (potentially large) piece of text data to the connection.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.function.Function<HttpClientResponse,Future<HttpClientRequest>> |
HttpClient.redirectHandler() |
| Modifier and Type | Method and Description |
|---|---|
void |
ServerWebSocket.setHandshake(Future<Integer> future)
Deprecated.
instead use
ServerWebSocket.setHandshake(Promise) |
| Modifier and Type | Method and Description |
|---|---|
HttpClient |
HttpClient.redirectHandler(java.util.function.Function<HttpClientResponse,Future<HttpClientRequest>> handler)
Set a redirect handler for the http client.
|
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
NetSocket.close()
Close the NetSocket
|
Future<Void> |
NetServer.close()
Close the server.
|
Future<NetSocket> |
NetClient.connect(int port,
String host)
Like
NetClient.connect(int, String, Handler) but returns a Future of the asynchronous result |
Future<NetSocket> |
NetClient.connect(int port,
String host,
String serverName)
Like
NetClient.connect(int, String, String, Handler) but returns a Future of the asynchronous result |
Future<NetSocket> |
NetClient.connect(SocketAddress remoteAddress)
Like
NetClient.connect(SocketAddress, Handler) but returns a Future of the asynchronous result |
Future<NetSocket> |
NetClient.connect(SocketAddress remoteAddress,
String serverName)
Like
NetClient.connect(SocketAddress, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
NetSocket.end()
Calls
NetSocket.close() |
Future<NetServer> |
NetServer.listen()
Start listening on the port and host as configured in the
NetServerOptions used when
creating the server. |
Future<NetServer> |
NetServer.listen(int port)
Start listening on the specified port and host "0.0.0.0", ignoring port and host configured in the
NetServerOptions used when creating the server. |
Future<NetServer> |
NetServer.listen(int port,
String host)
Start listening on the specified port and host, ignoring port and host configured in the
NetServerOptions used when
creating the server. |
Future<NetServer> |
NetServer.listen(SocketAddress localAddress)
Start listening on the specified local address, ignoring port and host configured in the
NetServerOptions used when
creating the server. |
default Future<Void> |
NetSocket.sendFile(String filename)
Tell the operating system to stream a file as specified by
filename directly from disk to the outgoing connection,
bypassing userspace altogether (where supported by the underlying operating system. |
default Future<Void> |
NetSocket.sendFile(String filename,
long offset)
Tell the operating system to stream a file as specified by
filename directly from disk to the outgoing connection,
bypassing userspace altogether (where supported by the underlying operating system. |
default Future<Void> |
NetSocket.sendFile(String filename,
long offset,
long length)
Tell the operating system to stream a file as specified by
filename directly from disk to the outgoing connection,
bypassing userspace altogether (where supported by the underlying operating system. |
default Future<Void> |
NetSocket.upgradeToSsl()
Like
NetSocket.upgradeToSsl(Handler) but returns a Future of the asynchronous result |
default Future<Void> |
NetSocket.upgradeToSsl(String serverName)
Like
NetSocket.upgradeToSsl(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
NetSocket.write(String str)
Write a
String to the connection, encoded in UTF-8. |
Future<Void> |
NetSocket.write(String str,
String enc)
Write a
String to the connection, encoded using the encoding enc. |
| Modifier and Type | Method and Description |
|---|---|
default Future<Long> |
Counter.addAndGet(long value)
Same as
Counter.addAndGet(long, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
AsyncMap.clear()
Same as
AsyncMap.clear(Handler) but returns a Future of the asynchronous result |
default Future<Boolean> |
Counter.compareAndSet(long expected,
long value)
Same as
Counter.compareAndSet(long, long, Handler) but returns a Future of the asynchronous result |
default Future<Long> |
Counter.decrementAndGet()
Same as
Counter.decrementAndGet(Handler) but returns a Future of the asynchronous result |
default Future<Map<K,V>> |
AsyncMap.entries()
Same as
AsyncMap.entries(Handler) but returns a Future of the asynchronous result |
default Future<Long> |
Counter.get()
Same as
Counter.get(Handler) but returns a Future of the asynchronous result |
default Future<V> |
AsyncMap.get(K k)
Same as
#get(K, Handler) but returns a Future of the asynchronous result |
default Future<Long> |
Counter.getAndAdd(long value)
Same as
Counter.getAndAdd(long, Handler) but returns a Future of the asynchronous result |
default Future<Long> |
Counter.getAndIncrement()
Same as
Counter.getAndIncrement(Handler) but returns a Future of the asynchronous result |
default <K,V> Future<AsyncMap<K,V>> |
SharedData.getAsyncMap(String name)
Same as
SharedData.getAsyncMap(String, Handler) but returns a Future of the asynchronous result |
default <K,V> Future<AsyncMap<K,V>> |
SharedData.getClusterWideMap(String name)
Same as
SharedData.getClusterWideMap(String, Handler) but returns a Future of the asynchronous result |
default Future<Counter> |
SharedData.getCounter(String name)
Same as
SharedData.getCounter(String, Handler) but returns a Future of the asynchronous result |
default <K,V> Future<AsyncMap<K,V>> |
SharedData.getLocalAsyncMap(String name)
Same as
SharedData.getLocalAsyncMap(String, Handler) but returns a Future of the asynchronous result |
default Future<Counter> |
SharedData.getLocalCounter(String name)
Same as
SharedData.getLocalCounter(String, Handler) but returns a Future of the asynchronous result |
default Future<Lock> |
SharedData.getLocalLock(String name)
Same as
SharedData.getLocalLock(String, Handler) but returns a Future of the asynchronous result |
default Future<Lock> |
SharedData.getLocalLockWithTimeout(String name,
long timeout)
Same as
SharedData.getLocalLockWithTimeout(String, long, Handler) but returns a Future of the asynchronous result |
default Future<Lock> |
SharedData.getLock(String name)
Same as
SharedData.getLock(String, Handler) but returns a Future of the asynchronous result |
default Future<Lock> |
SharedData.getLockWithTimeout(String name,
long timeout)
Same as
SharedData.getLockWithTimeout(String, long, Handler) but returns a Future of the asynchronous result |
default Future<Long> |
Counter.incrementAndGet()
Same as
Counter.incrementAndGet(Handler) but returns a Future of the asynchronous result |
default Future<Set<K>> |
AsyncMap.keys()
Same as
AsyncMap.keys(Handler) but returns a Future of the asynchronous result |
default Future<Void> |
AsyncMap.put(K k,
V v)
Same as
#put(K, V, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
AsyncMap.put(K k,
V v,
long ttl)
Same as
#put(K, V, long, Handler) but returns a Future of the asynchronous result |
default Future<V> |
AsyncMap.putIfAbsent(K k,
V v)
Same as
#putIfAbsent(K, V, Handler) but returns a Future of the asynchronous result |
default Future<V> |
AsyncMap.putIfAbsent(K k,
V v,
long ttl)
Same as
#putIfAbsent(K, V, long, Handler) but returns a Future of the asynchronous result |
default Future<V> |
AsyncMap.remove(K k)
Same as
#remove(K, Handler) but returns a Future of the asynchronous result |
default Future<Boolean> |
AsyncMap.removeIfPresent(K k,
V v)
Same as
#removeIfPresent(K, V, Handler) but returns a Future of the asynchronous result |
default Future<V> |
AsyncMap.replace(K k,
V v)
Same as
#replace(K, V, Handler) but returns a Future of the asynchronous result |
default Future<Boolean> |
AsyncMap.replaceIfPresent(K k,
V oldValue,
V newValue)
Same as
#replaceIfPresent(K, V, V, Handler) but returns a Future of the asynchronous result |
default Future<Integer> |
AsyncMap.size()
Same as
AsyncMap.size(Handler) but returns a Future of the asynchronous result |
default Future<List<V>> |
AsyncMap.values()
Same as
AsyncMap.values(Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Method and Description |
|---|---|
<T> Future<T> |
FutureFactory.failedFuture(Throwable t) |
<T> Future<T> |
FutureFactory.failureFuture(String failureMessage) |
<T> Future<T> |
FutureFactory.future() |
<T> Future<T> |
FutureFactory.succeededFuture() |
<T> Future<T> |
FutureFactory.succeededFuture(T result) |
| Modifier and Type | Method and Description |
|---|---|
default Future<Void> |
WriteStream.end()
Ends the stream.
|
default Future<Void> |
WriteStream.end(T data)
Same as
WriteStream.end() but writes some data to the stream before ending. |
default Future<Void> |
ReadStream.pipeTo(WriteStream<T> dst)
Same as
ReadStream.pipeTo(WriteStream, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
Pipe.to(WriteStream<T> dst)
Same as
Pipe.to(WriteStream, Handler) but returns a Future of the asynchronous result |
Future<Void> |
WriteStream.write(T data)
Write some data to the stream.
|
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
ReactiveWriteStream.write(T data) |
| Modifier and Type | Method and Description |
|---|---|
Future<T> |
BodyStream.result() |
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
SockJSSocket.end()
Call
SockJSSocket.close(). |
default Future<Void> |
SockJSSocket.write(Buffer data) |
| Modifier and Type | Method and Description |
|---|---|
<T> Future<T> |
VertxTestContext.assertComplete(Future<T> fut)
This method allows you to check if a future is completed.
|
<T> Future<T> |
VertxTestContext.assertFailure(Future<T> fut)
This method allows you to check if a future is failed.
|
| Modifier and Type | Method and Description |
|---|---|
<T> Future<T> |
VertxTestContext.assertComplete(Future<T> fut)
This method allows you to check if a future is completed.
|
<T> Future<T> |
VertxTestContext.assertFailure(Future<T> fut)
This method allows you to check if a future is failed.
|
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
KafkaProducer.write(KafkaProducerRecord<K,V> kafkaProducerRecord) |
| Modifier and Type | Method and Description |
|---|---|
Future |
Future.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static <T> Future<T> |
Future.newInstance(Future arg) |
static <T> Future<T> |
Future.newInstance(Future arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
| Constructor and Description |
|---|
Future(Future delegate) |
Future(Future delegate,
io.vertx.lang.rx.TypeArg<T> typeArg_0) |
| Modifier and Type | Method and Description |
|---|---|
default Future<Response> |
RedisAPI.append(String arg0,
String arg1)
Redis command append.
|
default Future<Response> |
RedisAPI.asking()
Redis command asking.
|
default Future<Response> |
RedisAPI.auth(String arg0)
Redis command auth.
|
default Future<List<Response>> |
Redis.batch(List<Request> commands)
Sends a list of commands in a single IO operation, this prevents any inter twinning to happen from other
client users.
|
default Future<Response> |
RedisAPI.bgrewriteaof()
Redis command bgrewriteaof.
|
default Future<Response> |
RedisAPI.bgsave(List<String> args)
Redis command bgsave.
|
default Future<Response> |
RedisAPI.bitcount(List<String> args)
Redis command bitcount.
|
default Future<Response> |
RedisAPI.bitfield(List<String> args)
Redis command bitfield.
|
default Future<Response> |
RedisAPI.bitop(List<String> args)
Redis command bitop.
|
default Future<Response> |
RedisAPI.bitpos(List<String> args)
Redis command bitpos.
|
default Future<Response> |
RedisAPI.blpop(List<String> args)
Redis command blpop.
|
default Future<Response> |
RedisAPI.brpop(List<String> args)
Redis command brpop.
|
default Future<Response> |
RedisAPI.brpoplpush(String arg0,
String arg1,
String arg2)
Redis command brpoplpush.
|
default Future<Response> |
RedisAPI.bzpopmax(List<String> args)
Redis command bzpopmax.
|
default Future<Response> |
RedisAPI.bzpopmin(List<String> args)
Redis command bzpopmin.
|
default Future<Response> |
RedisAPI.client(List<String> args)
Redis command client.
|
default Future<Response> |
RedisAPI.cluster(List<String> args)
Redis command cluster.
|
default Future<Response> |
RedisAPI.command()
Redis command command.
|
default Future<Response> |
RedisAPI.config(List<String> args)
Redis command config.
|
default Future<Redis> |
Redis.connect()
Connects to the redis server.
|
default Future<Response> |
RedisAPI.dbsize()
Redis command dbsize.
|
default Future<Response> |
RedisAPI.debug(List<String> args)
Redis command debug.
|
default Future<Response> |
RedisAPI.decr(String arg0)
Redis command decr.
|
default Future<Response> |
RedisAPI.decrby(String arg0,
String arg1)
Redis command decrby.
|
default Future<Response> |
RedisAPI.del(List<String> args)
Redis command del.
|
default Future<Response> |
RedisAPI.discard()
Redis command discard.
|
default Future<Response> |
RedisAPI.dump(String arg0)
Redis command dump.
|
default Future<Response> |
RedisAPI.echo(String arg0)
Redis command echo.
|
default Future<Response> |
RedisAPI.eval(List<String> args)
Redis command eval.
|
default Future<Response> |
RedisAPI.evalsha(List<String> args)
Redis command evalsha.
|
default Future<Response> |
RedisAPI.exec()
Redis command exec.
|
default Future<Response> |
RedisAPI.exists(List<String> args)
Redis command exists.
|
default Future<Response> |
RedisAPI.expire(String arg0,
String arg1)
Redis command expire.
|
default Future<Response> |
RedisAPI.expireat(String arg0,
String arg1)
Redis command expireat.
|
default Future<Response> |
RedisAPI.flushall(List<String> args)
Redis command flushall.
|
default Future<Response> |
RedisAPI.flushdb(List<String> args)
Redis command flushdb.
|
default Future<Response> |
RedisAPI.geoadd(List<String> args)
Redis command geoadd.
|
default Future<Response> |
RedisAPI.geodist(List<String> args)
Redis command geodist.
|
default Future<Response> |
RedisAPI.geohash(List<String> args)
Redis command geohash.
|
default Future<Response> |
RedisAPI.geopos(List<String> args)
Redis command geopos.
|
default Future<Response> |
RedisAPI.georadius(List<String> args)
Redis command georadius.
|
default Future<Response> |
RedisAPI.georadiusbymember(List<String> args)
Redis command georadiusbymember.
|
default Future<Response> |
RedisAPI.georadiusbymemberRo(List<String> args)
Redis command georadiusbymemberRo.
|
default Future<Response> |
RedisAPI.georadiusRo(List<String> args)
Redis command georadiusRo.
|
default Future<Response> |
RedisAPI.get(String arg0)
Redis command get.
|
default Future<Response> |
RedisAPI.getbit(String arg0,
String arg1)
Redis command getbit.
|
default Future<Response> |
RedisAPI.getrange(String arg0,
String arg1,
String arg2)
Redis command getrange.
|
default Future<Response> |
RedisAPI.getset(String arg0,
String arg1)
Redis command getset.
|
default Future<Response> |
RedisAPI.hdel(List<String> args)
Redis command hdel.
|
default Future<Response> |
RedisAPI.hexists(String arg0,
String arg1)
Redis command hexists.
|
default Future<Response> |
RedisAPI.hget(String arg0,
String arg1)
Redis command hget.
|
default Future<Response> |
RedisAPI.hgetall(String arg0)
Redis command hgetall.
|
default Future<Response> |
RedisAPI.hincrby(String arg0,
String arg1,
String arg2)
Redis command hincrby.
|
default Future<Response> |
RedisAPI.hincrbyfloat(String arg0,
String arg1,
String arg2)
Redis command hincrbyfloat.
|
default Future<Response> |
RedisAPI.hkeys(String arg0)
Redis command hkeys.
|
default Future<Response> |
RedisAPI.hlen(String arg0)
Redis command hlen.
|
default Future<Response> |
RedisAPI.hmget(List<String> args)
Redis command hmget.
|
default Future<Response> |
RedisAPI.hmset(List<String> args)
Redis command hmset.
|
default Future<Response> |
RedisAPI.host(List<String> args)
Redis command host.
|
default Future<Response> |
RedisAPI.hscan(List<String> args)
Redis command hscan.
|
default Future<Response> |
RedisAPI.hset(List<String> args)
Redis command hset.
|
default Future<Response> |
RedisAPI.hsetnx(String arg0,
String arg1,
String arg2)
Redis command hsetnx.
|
default Future<Response> |
RedisAPI.hstrlen(String arg0,
String arg1)
Redis command hstrlen.
|
default Future<Response> |
RedisAPI.hvals(String arg0)
Redis command hvals.
|
default Future<Response> |
RedisAPI.incr(String arg0)
Redis command incr.
|
default Future<Response> |
RedisAPI.incrby(String arg0,
String arg1)
Redis command incrby.
|
default Future<Response> |
RedisAPI.incrbyfloat(String arg0,
String arg1)
Redis command incrbyfloat.
|
default Future<Response> |
RedisAPI.info(List<String> args)
Redis command info.
|
default Future<Response> |
RedisAPI.keys(String arg0)
Redis command keys.
|
default Future<Response> |
RedisAPI.lastsave()
Redis command lastsave.
|
default Future<Response> |
RedisAPI.latency(List<String> args)
Redis command latency.
|
default Future<Response> |
RedisAPI.lindex(String arg0,
String arg1)
Redis command lindex.
|
default Future<Response> |
RedisAPI.linsert(String arg0,
String arg1,
String arg2,
String arg3)
Redis command linsert.
|
default Future<Response> |
RedisAPI.llen(String arg0)
Redis command llen.
|
default Future<Response> |
RedisAPI.lolwut(List<String> args)
Redis command lolwut.
|
default Future<Response> |
RedisAPI.lpop(String arg0)
Redis command lpop.
|
default Future<Response> |
RedisAPI.lpush(List<String> args)
Redis command lpush.
|
default Future<Response> |
RedisAPI.lpushx(List<String> args)
Redis command lpushx.
|
default Future<Response> |
RedisAPI.lrange(String arg0,
String arg1,
String arg2)
Redis command lrange.
|
default Future<Response> |
RedisAPI.lrem(String arg0,
String arg1,
String arg2)
Redis command lrem.
|
default Future<Response> |
RedisAPI.lset(String arg0,
String arg1,
String arg2)
Redis command lset.
|
default Future<Response> |
RedisAPI.ltrim(String arg0,
String arg1,
String arg2)
Redis command ltrim.
|
default Future<Response> |
RedisAPI.memory(List<String> args)
Redis command memory.
|
default Future<Response> |
RedisAPI.mget(List<String> args)
Redis command mget.
|
default Future<Response> |
RedisAPI.migrate(List<String> args)
Redis command migrate.
|
default Future<Response> |
RedisAPI.module(List<String> args)
Redis command module.
|
default Future<Response> |
RedisAPI.monitor()
Redis command monitor.
|
default Future<Response> |
RedisAPI.move(String arg0,
String arg1)
Redis command move.
|
default Future<Response> |
RedisAPI.mset(List<String> args)
Redis command mset.
|
default Future<Response> |
RedisAPI.msetnx(List<String> args)
Redis command msetnx.
|
default Future<Response> |
RedisAPI.multi()
Redis command multi.
|
default Future<Response> |
RedisAPI.object(List<String> args)
Redis command object.
|
default Future<Response> |
RedisAPI.persist(String arg0)
Redis command persist.
|
default Future<Response> |
RedisAPI.pexpire(String arg0,
String arg1)
Redis command pexpire.
|
default Future<Response> |
RedisAPI.pexpireat(String arg0,
String arg1)
Redis command pexpireat.
|
default Future<Response> |
RedisAPI.pfadd(List<String> args)
Redis command pfadd.
|
default Future<Response> |
RedisAPI.pfcount(List<String> args)
Redis command pfcount.
|
default Future<Response> |
RedisAPI.pfdebug(List<String> args)
Redis command pfdebug.
|
default Future<Response> |
RedisAPI.pfmerge(List<String> args)
Redis command pfmerge.
|
default Future<Response> |
RedisAPI.pfselftest()
Redis command pfselftest.
|
default Future<Response> |
RedisAPI.ping(List<String> args)
Redis command ping.
|
default Future<Response> |
RedisAPI.post(List<String> args)
Redis command post.
|
default Future<Response> |
RedisAPI.psetex(String arg0,
String arg1,
String arg2)
Redis command psetex.
|
default Future<Response> |
RedisAPI.psubscribe(List<String> args)
Redis command psubscribe.
|
default Future<Response> |
RedisAPI.psync(String arg0,
String arg1)
Redis command psync.
|
default Future<Response> |
RedisAPI.pttl(String arg0)
Redis command pttl.
|
default Future<Response> |
RedisAPI.publish(String arg0,
String arg1)
Redis command publish.
|
default Future<Response> |
RedisAPI.pubsub(List<String> args)
Redis command pubsub.
|
default Future<Response> |
RedisAPI.punsubscribe(List<String> args)
Redis command punsubscribe.
|
default Future<Response> |
RedisAPI.randomkey()
Redis command randomkey.
|
default Future<Response> |
RedisAPI.readonly()
Redis command readonly.
|
default Future<Response> |
RedisAPI.readwrite()
Redis command readwrite.
|
default Future<Response> |
RedisAPI.rename(String arg0,
String arg1)
Redis command rename.
|
default Future<Response> |
RedisAPI.renamenx(String arg0,
String arg1)
Redis command renamenx.
|
default Future<Response> |
RedisAPI.replconf(List<String> args)
Redis command replconf.
|
default Future<Response> |
RedisAPI.replicaof(String arg0,
String arg1)
Redis command replicaof.
|
default Future<Response> |
RedisAPI.restore(List<String> args)
Redis command restore.
|
default Future<Response> |
RedisAPI.restoreAsking(List<String> args)
Redis command restoreAsking.
|
default Future<Response> |
RedisAPI.role()
Redis command role.
|
default Future<Response> |
RedisAPI.rpop(String arg0)
Redis command rpop.
|
default Future<Response> |
RedisAPI.rpoplpush(String arg0,
String arg1)
Redis command rpoplpush.
|
default Future<Response> |
RedisAPI.rpush(List<String> args)
Redis command rpush.
|
default Future<Response> |
RedisAPI.rpushx(List<String> args)
Redis command rpushx.
|
default Future<Response> |
RedisAPI.sadd(List<String> args)
Redis command sadd.
|
default Future<Response> |
RedisAPI.save()
Redis command save.
|
default Future<Response> |
RedisAPI.scan(List<String> args)
Redis command scan.
|
default Future<Response> |
RedisAPI.scard(String arg0)
Redis command scard.
|
default Future<Response> |
RedisAPI.script(List<String> args)
Redis command script.
|
default Future<Response> |
RedisAPI.sdiff(List<String> args)
Redis command sdiff.
|
default Future<Response> |
RedisAPI.sdiffstore(List<String> args)
Redis command sdiffstore.
|
default Future<Response> |
RedisAPI.select(String arg0)
Redis command select.
|
Future<Response> |
RedisAPI.send(Command cmd,
String... args)
Send untyped command to redis.
|
default Future<Response> |
Redis.send(Request command)
Send the given command to the redis server or cluster.
|
default Future<Response> |
RedisAPI.set(List<String> args)
Redis command set.
|
default Future<Response> |
RedisAPI.setbit(String arg0,
String arg1,
String arg2)
Redis command setbit.
|
default Future<Response> |
RedisAPI.setex(String arg0,
String arg1,
String arg2)
Redis command setex.
|
default Future<Response> |
RedisAPI.setnx(String arg0,
String arg1)
Redis command setnx.
|
default Future<Response> |
RedisAPI.setrange(String arg0,
String arg1,
String arg2)
Redis command setrange.
|
default Future<Response> |
RedisAPI.shutdown(List<String> args)
Redis command shutdown.
|
default Future<Response> |
RedisAPI.sinter(List<String> args)
Redis command sinter.
|
default Future<Response> |
RedisAPI.sinterstore(List<String> args)
Redis command sinterstore.
|
default Future<Response> |
RedisAPI.sismember(String arg0,
String arg1)
Redis command sismember.
|
default Future<Response> |
RedisAPI.slaveof(String arg0,
String arg1)
Redis command slaveof.
|
default Future<Response> |
RedisAPI.slowlog(List<String> args)
Redis command slowlog.
|
default Future<Response> |
RedisAPI.smembers(String arg0)
Redis command smembers.
|
default Future<Response> |
RedisAPI.smove(String arg0,
String arg1,
String arg2)
Redis command smove.
|
default Future<Response> |
RedisAPI.sort(List<String> args)
Redis command sort.
|
default Future<Response> |
RedisAPI.spop(List<String> args)
Redis command spop.
|
default Future<Response> |
RedisAPI.srandmember(List<String> args)
Redis command srandmember.
|
default Future<Response> |
RedisAPI.srem(List<String> args)
Redis command srem.
|
default Future<Response> |
RedisAPI.sscan(List<String> args)
Redis command sscan.
|
default Future<Response> |
RedisAPI.strlen(String arg0)
Redis command strlen.
|
default Future<Response> |
RedisAPI.subscribe(List<String> args)
Redis command subscribe.
|
default Future<Response> |
RedisAPI.substr(String arg0,
String arg1,
String arg2)
Redis command substr.
|
default Future<Response> |
RedisAPI.sunion(List<String> args)
Redis command sunion.
|
default Future<Response> |
RedisAPI.sunionstore(List<String> args)
Redis command sunionstore.
|
default Future<Response> |
RedisAPI.swapdb(String arg0,
String arg1)
Redis command swapdb.
|
default Future<Response> |
RedisAPI.sync()
Redis command sync.
|
default Future<Response> |
RedisAPI.time()
Redis command time.
|
default Future<Response> |
RedisAPI.touch(List<String> args)
Redis command touch.
|
default Future<Response> |
RedisAPI.ttl(String arg0)
Redis command ttl.
|
default Future<Response> |
RedisAPI.type(String arg0)
Redis command type.
|
default Future<Response> |
RedisAPI.unlink(List<String> args)
Redis command unlink.
|
default Future<Response> |
RedisAPI.unsubscribe(List<String> args)
Redis command unsubscribe.
|
default Future<Response> |
RedisAPI.unwatch()
Redis command unwatch.
|
default Future<Response> |
RedisAPI.wait(String arg0,
String arg1)
Redis command wait.
|
default Future<Response> |
RedisAPI.watch(List<String> args)
Redis command watch.
|
default Future<Response> |
RedisAPI.xack(List<String> args)
Redis command xack.
|
default Future<Response> |
RedisAPI.xadd(List<String> args)
Redis command xadd.
|
default Future<Response> |
RedisAPI.xclaim(List<String> args)
Redis command xclaim.
|
default Future<Response> |
RedisAPI.xdel(List<String> args)
Redis command xdel.
|
default Future<Response> |
RedisAPI.xgroup(List<String> args)
Redis command xgroup.
|
default Future<Response> |
RedisAPI.xinfo(List<String> args)
Redis command xinfo.
|
default Future<Response> |
RedisAPI.xlen(String arg0)
Redis command xlen.
|
default Future<Response> |
RedisAPI.xpending(List<String> args)
Redis command xpending.
|
default Future<Response> |
RedisAPI.xrange(List<String> args)
Redis command xrange.
|
default Future<Response> |
RedisAPI.xread(List<String> args)
Redis command xread.
|
default Future<Response> |
RedisAPI.xreadgroup(List<String> args)
Redis command xreadgroup.
|
default Future<Response> |
RedisAPI.xrevrange(List<String> args)
Redis command xrevrange.
|
default Future<Response> |
RedisAPI.xsetid(String arg0,
String arg1)
Redis command xsetid.
|
default Future<Response> |
RedisAPI.xtrim(List<String> args)
Redis command xtrim.
|
default Future<Response> |
RedisAPI.zadd(List<String> args)
Redis command zadd.
|
default Future<Response> |
RedisAPI.zcard(String arg0)
Redis command zcard.
|
default Future<Response> |
RedisAPI.zcount(String arg0,
String arg1,
String arg2)
Redis command zcount.
|
default Future<Response> |
RedisAPI.zincrby(String arg0,
String arg1,
String arg2)
Redis command zincrby.
|
default Future<Response> |
RedisAPI.zinterstore(List<String> args)
Redis command zinterstore.
|
default Future<Response> |
RedisAPI.zlexcount(String arg0,
String arg1,
String arg2)
Redis command zlexcount.
|
default Future<Response> |
RedisAPI.zpopmax(List<String> args)
Redis command zpopmax.
|
default Future<Response> |
RedisAPI.zpopmin(List<String> args)
Redis command zpopmin.
|
default Future<Response> |
RedisAPI.zrange(List<String> args)
Redis command zrange.
|
default Future<Response> |
RedisAPI.zrangebylex(List<String> args)
Redis command zrangebylex.
|
default Future<Response> |
RedisAPI.zrangebyscore(List<String> args)
Redis command zrangebyscore.
|
default Future<Response> |
RedisAPI.zrank(String arg0,
String arg1)
Redis command zrank.
|
default Future<Response> |
RedisAPI.zrem(List<String> args)
Redis command zrem.
|
default Future<Response> |
RedisAPI.zremrangebylex(String arg0,
String arg1,
String arg2)
Redis command zremrangebylex.
|
default Future<Response> |
RedisAPI.zremrangebyrank(String arg0,
String arg1,
String arg2)
Redis command zremrangebyrank.
|
default Future<Response> |
RedisAPI.zremrangebyscore(String arg0,
String arg1,
String arg2)
Redis command zremrangebyscore.
|
default Future<Response> |
RedisAPI.zrevrange(List<String> args)
Redis command zrevrange.
|
default Future<Response> |
RedisAPI.zrevrangebylex(List<String> args)
Redis command zrevrangebylex.
|
default Future<Response> |
RedisAPI.zrevrangebyscore(List<String> args)
Redis command zrevrangebyscore.
|
default Future<Response> |
RedisAPI.zrevrank(String arg0,
String arg1)
Redis command zrevrank.
|
default Future<Response> |
RedisAPI.zscan(List<String> args)
Redis command zscan.
|
default Future<Response> |
RedisAPI.zscore(String arg0,
String arg1)
Redis command zscore.
|
default Future<Response> |
RedisAPI.zunionstore(List<String> args)
Redis command zunionstore.
|
| Modifier and Type | Method and Description |
|---|---|
Future |
Future.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static <T> Future<T> |
Future.newInstance(Future arg) |
static <T> Future<T> |
Future.newInstance(Future arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
| Constructor and Description |
|---|
Future(Future delegate) |
Future(Future delegate,
io.vertx.lang.rx.TypeArg<T> typeArg_0) |
| Modifier and Type | Method and Description |
|---|---|
Future<Message<JsonObject>> |
ServiceJWTInterceptor.apply(Message<JsonObject> msg) |
| Modifier and Type | Method and Description |
|---|---|
ServiceBinder |
ServiceBinder.addInterceptor(java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>> interceptor) |
MessageConsumer<JsonObject> |
ProxyHandler.register(EventBus eventBus,
String address,
List<java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>>> interceptors)
Register the proxy handle on the event bus.
|
MessageConsumer<JsonObject> |
ProxyHandler.registerLocal(EventBus eventBus,
String address,
List<java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>>> interceptors)
Register the local proxy handle on the event bus.
|
Copyright © 2019 Eclipse. All rights reserved.