Package | Description |
---|---|
io.vertx.core | |
io.vertx.core.datagram | |
io.vertx.core.dns | |
io.vertx.core.eventbus | |
io.vertx.core.file | |
io.vertx.core.http | |
io.vertx.core.net | |
io.vertx.core.shareddata | |
io.vertx.core.streams |
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.
|
Future<Void> |
WorkerExecutor.close()
Like
WorkerExecutor.close(Handler) but returns a Future of the asynchronous result |
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(Function<T,Future<U>> mapper)
Compose this future with a
mapper function. |
<U> Future<U> |
Future.compose(Function<T,Future<U>> successMapper,
Function<Throwable,Future<U>> failureMapper)
Compose this future with a
successMapper and failureMapper functions. |
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(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. |
<U> Future<T> |
Future.eventually(Function<Void,Future<U>> mapper)
Compose this future with a
mapper that will be always be called. |
<T> Future<T> |
Context.executeBlocking(Handler<Promise<T>> blockingCodeHandler)
Same as
Context.executeBlocking(Handler, Handler) but with an handler called when the operation completes |
<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. |
<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 |
<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 |
<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.
|
default <U> Future<U> |
Future.flatMap(Function<T,Future<U>> mapper)
Alias for
compose(Function) . |
static <T> Future<T> |
Future.fromCompletionStage(CompletionStage<T> completionStage)
Bridges a
CompletionStage object to a Vert.x future instance. |
static <T> Future<T> |
Future.fromCompletionStage(CompletionStage<T> completionStage,
Context context)
Bridges a
CompletionStage object to a Vert.x future instance. |
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. |
<U> Future<U> |
Future.map(Function<T,U> mapper)
Apply a
mapper function on this future. |
<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 . |
Future<T> |
Future.onComplete(Handler<AsyncResult<T>> handler)
Add a handler to be notified of the result.
|
default Future<T> |
Future.onFailure(Handler<Throwable> handler)
Add a handler to be notified of the failed result.
|
default Future<T> |
Future.onSuccess(Handler<T> handler)
Add a handler to be notified of the succeeded result.
|
Future<T> |
Future.otherwise(Function<Throwable,T> mapper)
Apply a
mapper function on this future. |
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(Function<Throwable,Future<T>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
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.
|
<U> Future<U> |
Future.transform(Function<AsyncResult<T>,Future<U>> mapper)
Transform this future with a
mapper functions. |
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(Function<T,Future<U>> mapper)
Compose this future with a
mapper function. |
<U> Future<U> |
Future.compose(Function<T,Future<U>> successMapper,
Function<Throwable,Future<U>> failureMapper)
Compose this future with a
successMapper and failureMapper functions. |
<U> Future<U> |
Future.compose(Function<T,Future<U>> successMapper,
Function<Throwable,Future<U>> failureMapper)
Compose this future with a
successMapper and failureMapper functions. |
<U> Future<T> |
Future.eventually(Function<Void,Future<U>> mapper)
Compose this future with a
mapper that will be always be called. |
default <U> Future<U> |
Future.flatMap(Function<T,Future<U>> mapper)
Alias for
compose(Function) . |
static CompositeFuture |
CompositeFuture.join(List<Future> futures)
Like
CompositeFuture.join(Future, Future) but with a list of futures. |
default Future<T> |
Future.recover(Function<Throwable,Future<T>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
<U> Future<U> |
Future.transform(Function<AsyncResult<T>,Future<U>> mapper)
Transform this future with a
mapper functions. |
Modifier and Type | Method and Description |
---|---|
Future<Void> |
DatagramSocket.blockMulticastGroup(String multicastAddress,
String sourceToBlock)
Like
DatagramSocket.blockMulticastGroup(String, String, Handler) but returns a Future of the asynchronous result |
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 |
Future<Void> |
DatagramSocket.close()
Closes the
DatagramSocket . |
Future<DatagramSocket> |
DatagramSocket.listen(int port,
String host)
Like
DatagramSocket.listen(int, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
DatagramSocket.listenMulticastGroup(String multicastAddress)
Like
DatagramSocket.listenMulticastGroup(String, Handler) but returns a Future of the asynchronous result |
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 |
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 |
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 |
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 |
Future<Void> |
DatagramSocket.unlistenMulticastGroup(String multicastAddress)
Like
DatagramSocket.unlistenMulticastGroup(String, Handler) but returns a Future of the asynchronous result |
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 |
---|---|
Future<String> |
DnsClient.lookup(String name)
Like
DnsClient.lookup(String, Handler) but returns a Future of the asynchronous result |
Future<String> |
DnsClient.lookup4(String name)
Like
DnsClient.lookup4(String, Handler) but returns a Future of the asynchronous result |
Future<String> |
DnsClient.lookup6(String name)
Like
DnsClient.lookup6(String, Handler) but returns a Future of the asynchronous result |
Future<List<String>> |
DnsClient.resolveA(String name)
Like
DnsClient.resolveA(String, Handler) but returns a Future of the asynchronous result |
Future<List<String>> |
DnsClient.resolveAAAA(String name)
Like
DnsClient.resolveAAAA(String, Handler) but returns a Future of the asynchronous result |
Future<List<String>> |
DnsClient.resolveCNAME(String name)
Like
DnsClient.resolveCNAME(String, Handler) but returns a Future of the asynchronous result |
Future<List<MxRecord>> |
DnsClient.resolveMX(String name)
Like
DnsClient.resolveMX(String, Handler) but returns a Future of the asynchronous result |
Future<List<String>> |
DnsClient.resolveNS(String name)
Like
DnsClient.resolveNS(String, Handler) but returns a Future of the asynchronous result |
Future<String> |
DnsClient.resolvePTR(String name)
Like
DnsClient.resolvePTR(String, Handler) but returns a Future of the asynchronous result |
Future<List<SrvRecord>> |
DnsClient.resolveSRV(String name)
Like
DnsClient.resolveSRV(String, Handler) but returns a Future of the asynchronous result |
Future<List<String>> |
DnsClient.resolveTXT(String name)
Like
DnsClient.resolveTXT(String, Handler) but returns a Future of the asynchronous result |
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.
|
default <R> Future<Message<R>> |
Message.replyAndRequest(Object message)
Like
Message.replyAndRequest(Object, Handler) but returns a Future of the asynchronous result |
<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 |
<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 |
Future<Void> |
MessageConsumer.unregister()
Unregisters the handler which created this registration
|
Future<Void> |
MessageProducer.write(T body)
Like
MessageProducer.write(Object, 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 | 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> |
HttpClient.close()
Like
HttpClient.close(Handler) but returns a Future of the asynchronous result |
Future<Void> |
HttpConnection.close()
Like
HttpConnection.close(Handler) but returns a Future of the asynchronous result |
Future<Void> |
HttpServer.close()
Close the server.
|
Future<Void> |
ServerWebSocket.close()
Close the WebSocket sending the default close frame.
|
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<HttpClientResponse> |
HttpClientRequest.connect()
Like
HttpClientRequest.connect(Handler) but returns a Future of the asynchronous result |
Future<Void> |
HttpClientRequest.end()
Ends the request.
|
Future<Void> |
HttpClientResponse.end()
Returns a future signaling when the response has been fully received successfully or failed.
|
Future<Void> |
HttpServerResponse.end()
Ends the response.
|
Future<Void> |
WebSocketBase.end()
Ends the stream.
|
Future<Void> |
HttpServerRequest.end()
Returns a future signaling when the request has been fully received successfully or failed.
|
Future<Void> |
HttpClientRequest.end(Buffer chunk)
Same as
HttpClientRequest.end() but writes some data to the request body before ending. |
Future<Void> |
HttpServerResponse.end(Buffer chunk)
Same as
HttpServerResponse.end() but writes some data to the response body before ending. |
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)
Same as
HttpServerResponse.end(Buffer) but writes a String in UTF-8 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 |
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<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 |
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 |
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 |
Future<HttpClientRequest> |
HttpClient.request(HttpMethod method,
int port,
String host,
String requestURI)
Like
HttpClient.request(HttpMethod, int, String, String, Handler) but returns a Future of the asynchronous result |
Future<HttpClientRequest> |
HttpClient.request(HttpMethod method,
String requestURI)
Like
HttpClient.request(HttpMethod, String, Handler) but returns a Future of the asynchronous result |
Future<HttpClientRequest> |
HttpClient.request(HttpMethod method,
String host,
String requestURI)
Like
HttpClient.request(HttpMethod, String, String, Handler) but returns a Future of the asynchronous result |
Future<HttpClientRequest> |
HttpClient.request(RequestOptions options)
Like
HttpClient.request(RequestOptions, Handler) but returns a Future of the asynchronous result |
Future<HttpClientResponse> |
HttpClientRequest.response() |
default Future<HttpClientResponse> |
HttpClientRequest.send()
Like
HttpClientRequest.send(Handler) but returns a Future of the asynchronous result |
default Future<Void> |
HttpServerResponse.send()
Like
HttpServerResponse.send(Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClientRequest.send(Buffer body)
Like
HttpClientRequest.send(Buffer, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
HttpServerResponse.send(Buffer body)
Like
HttpServerResponse.send(Buffer, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClientRequest.send(ReadStream<Buffer> body)
Like
HttpClientRequest.send(ReadStream, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
HttpServerResponse.send(ReadStream<Buffer> body)
Like
HttpServerResponse.send(ReadStream, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClientRequest.send(String body)
Like
HttpClientRequest.send(String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
HttpServerResponse.send(String body)
Like
HttpServerResponse.send(String, Handler) but returns a Future of the asynchronous result |
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. |
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> |
HttpClientRequest.sendHead()
Forces the head of the request to be written before
HttpClientRequest.end() is called on the request or any data is
written to it. |
Future<Integer> |
ServerWebSocket.setHandshake(Future<Integer> future)
Like
ServerWebSocket.setHandshake(Future, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
HttpConnection.shutdown()
Like
HttpConnection.shutdown(Handler) but returns a Future of the asynchronous result |
Future<Void> |
HttpConnection.shutdown(long timeoutMs)
Like
HttpConnection.shutdown(long, Handler) but returns a Future of the asynchronous result |
Future<Void> |
HttpServerFileUpload.streamToFileSystem(String filename)
Stream the content of this upload to the given file on storage.
|
Future<NetSocket> |
HttpServerRequest.toNetSocket()
Like
HttpServerRequest.toNetSocket(Handler) but returns a Future of the asynchronous result |
Future<ServerWebSocket> |
HttpServerRequest.toWebSocket()
Like
HttpServerRequest.toWebSocket(Handler) but returns a Future of the asynchronous result |
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> |
HttpClientRequest.write(String chunk)
Write a
String to the request body, encoded as UTF-8. |
Future<Void> |
HttpServerResponse.write(String chunk)
Write a
String to the response body, encoded in UTF-8. |
Future<Void> |
HttpClientRequest.write(String chunk,
String enc)
Write a
String to the request body, encoded using the encoding enc . |
Future<Void> |
HttpServerResponse.write(String chunk,
String enc)
Write a
String to the response 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.writePing(Buffer data)
Like
WebSocketBase.writePing(Buffer, Handler) but with an handler called when the message has been written
or failed to be written. |
Future<Void> |
WebSocketBase.writePong(Buffer data)
Like
WebSocketBase.writePong(Buffer, Handler) but with an handler called when the message has been written
or failed to be written. |
Future<Void> |
WebSocketBase.writeTextMessage(String text)
Writes a (potentially large) piece of text data to the connection.
|
Modifier and Type | Method and Description |
---|---|
Function<HttpClientResponse,Future<RequestOptions>> |
HttpClient.redirectHandler() |
Modifier and Type | Method and Description |
---|---|
Future<Integer> |
ServerWebSocket.setHandshake(Future<Integer> future)
Like
ServerWebSocket.setHandshake(Future, Handler) but returns a Future of the asynchronous result |
void |
ServerWebSocket.setHandshake(Future<Integer> future,
Handler<AsyncResult<Integer>> handler)
Set an asynchronous result for the handshake, upon completion of the specified
future , the
WebSocket will either be
accepted when the future succeeds with the HTTP 101 status code
rejected when the future is succeeds with an HTTP status code different than 101
rejected when the future fails with the HTTP status code 500
The provided future might be completed by the WebSocket itself, e.g calling the ServerWebSocket.close() method
will try to accept the handshake and close the WebSocket afterward. |
Modifier and Type | Method and Description |
---|---|
HttpClient |
HttpClient.redirectHandler(Function<HttpClientResponse,Future<RequestOptions>> handler)
Set a redirect handler for the http client.
|
Modifier and Type | Method and Description |
---|---|
Future<Void> |
NetClient.close()
Like
NetClient.close(Handler) but returns a Future of the asynchronous result |
Future<Void> |
NetServer.close()
Close the server.
|
Future<Void> |
NetSocket.close()
Close the NetSocket
|
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. |
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. |
Future<Void> |
NetSocket.upgradeToSsl()
Like
NetSocket.upgradeToSsl(Handler) but returns a Future of the asynchronous result |
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 |
---|---|
Future<Long> |
Counter.addAndGet(long value)
Same as
Counter.addAndGet(long, Handler) but returns a Future of the asynchronous result |
Future<Void> |
AsyncMap.clear()
Same as
AsyncMap.clear(Handler) but returns a Future of the asynchronous result |
Future<Boolean> |
Counter.compareAndSet(long expected,
long value)
Same as
Counter.compareAndSet(long, long, Handler) but returns a Future of the asynchronous result |
Future<Long> |
Counter.decrementAndGet()
Same as
Counter.decrementAndGet(Handler) but returns a Future of the asynchronous result |
Future<Map<K,V>> |
AsyncMap.entries()
Same as
AsyncMap.entries(Handler) but returns a Future of the asynchronous result |
Future<Long> |
Counter.get()
Same as
Counter.get(Handler) but returns a Future of the asynchronous result |
Future<V> |
AsyncMap.get(K k)
Same as
#get(K, Handler) but returns a Future of the asynchronous result |
Future<Long> |
Counter.getAndAdd(long value)
Same as
Counter.getAndAdd(long, Handler) but returns a Future of the asynchronous result |
Future<Long> |
Counter.getAndIncrement()
Same as
Counter.getAndIncrement(Handler) but returns a Future of the asynchronous result |
<K,V> Future<AsyncMap<K,V>> |
SharedData.getAsyncMap(String name)
Same as
SharedData.getAsyncMap(String, Handler) but returns a Future of the asynchronous result |
<K,V> Future<AsyncMap<K,V>> |
SharedData.getClusterWideMap(String name)
Same as
SharedData.getClusterWideMap(String, Handler) but returns a Future of the asynchronous result |
Future<Counter> |
SharedData.getCounter(String name)
Same as
SharedData.getCounter(String, Handler) but returns a Future of the asynchronous result |
<K,V> Future<AsyncMap<K,V>> |
SharedData.getLocalAsyncMap(String name)
Same as
SharedData.getLocalAsyncMap(String, Handler) but returns a Future of the asynchronous result |
Future<Counter> |
SharedData.getLocalCounter(String name)
Same as
SharedData.getLocalCounter(String, Handler) but returns a Future of the asynchronous result |
Future<Lock> |
SharedData.getLocalLock(String name)
Same as
SharedData.getLocalLock(String, Handler) but returns a Future of the asynchronous result |
Future<Lock> |
SharedData.getLocalLockWithTimeout(String name,
long timeout)
Same as
SharedData.getLocalLockWithTimeout(String, long, Handler) but returns a Future of the asynchronous result |
Future<Lock> |
SharedData.getLock(String name)
Same as
SharedData.getLock(String, Handler) but returns a Future of the asynchronous result |
Future<Lock> |
SharedData.getLockWithTimeout(String name,
long timeout)
Same as
SharedData.getLockWithTimeout(String, long, Handler) but returns a Future of the asynchronous result |
Future<Long> |
Counter.incrementAndGet()
Same as
Counter.incrementAndGet(Handler) but returns a Future of the asynchronous result |
Future<Set<K>> |
AsyncMap.keys()
Same as
AsyncMap.keys(Handler) but returns a Future of the asynchronous result |
Future<Void> |
AsyncMap.put(K k,
V v)
Same as
#put(K, V, Handler) but returns a Future of the asynchronous result |
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 |
Future<V> |
AsyncMap.putIfAbsent(K k,
V v)
Same as
#putIfAbsent(K, V, Handler) but returns a Future of the asynchronous result |
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 |
Future<V> |
AsyncMap.remove(K k)
Same as
#remove(K, Handler) but returns a Future of the asynchronous result |
Future<Boolean> |
AsyncMap.removeIfPresent(K k,
V v)
Same as
#removeIfPresent(K, V, Handler) but returns a Future of the asynchronous result |
Future<V> |
AsyncMap.replace(K k,
V v)
Same as
#replace(K, V, Handler) but returns a Future of the asynchronous result |
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 |
Future<Integer> |
AsyncMap.size()
Same as
AsyncMap.size(Handler) but returns a Future of the asynchronous result |
Future<List<V>> |
AsyncMap.values()
Same as
AsyncMap.values(Handler) but returns a Future of the asynchronous 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.
|
Copyright © 2021 Eclipse. All rights reserved.