Modifier and Type | Method and Description |
---|---|
<T> Future<T> |
CircuitBreaker.execute(io.vertx.core.Handler<Future<T>> command)
Same as
CircuitBreaker.executeWithFallback(io.vertx.core.Handler<io.vertx.rxjava.core.Future<T>>, java.util.function.Function<java.lang.Throwable, T>) but using the circuit breaker default fallback. |
<T> Future<T> |
CircuitBreaker.executeWithFallback(io.vertx.core.Handler<Future<T>> command,
Function<Throwable,T> fallback)
Executes the given operation with the circuit breaker control.
|
Modifier and Type | Method and Description |
---|---|
<T> CircuitBreaker |
CircuitBreaker.executeAndReport(Future<T> resultFuture,
io.vertx.core.Handler<Future<T>> command)
Same as
CircuitBreaker.executeAndReportWithFallback(io.vertx.rxjava.core.Future<T>, io.vertx.core.Handler<io.vertx.rxjava.core.Future<T>>, java.util.function.Function<java.lang.Throwable, T>) but using the circuit breaker default
fallback. |
<T> CircuitBreaker |
CircuitBreaker.executeAndReportWithFallback(Future<T> resultFuture,
io.vertx.core.Handler<Future<T>> command,
Function<Throwable,T> fallback)
Executes the given operation with the circuit breaker control.
|
Modifier and Type | Method and Description |
---|---|
<T> Future<T> |
CircuitBreaker.execute(io.vertx.core.Handler<Future<T>> command)
Same as
CircuitBreaker.executeWithFallback(io.vertx.core.Handler<io.vertx.rxjava.core.Future<T>>, java.util.function.Function<java.lang.Throwable, T>) but using the circuit breaker default fallback. |
<T> CircuitBreaker |
CircuitBreaker.executeAndReport(Future<T> resultFuture,
io.vertx.core.Handler<Future<T>> command)
Same as
CircuitBreaker.executeAndReportWithFallback(io.vertx.rxjava.core.Future<T>, io.vertx.core.Handler<io.vertx.rxjava.core.Future<T>>, java.util.function.Function<java.lang.Throwable, T>) but using the circuit breaker default
fallback. |
<T> CircuitBreaker |
CircuitBreaker.executeAndReportWithFallback(Future<T> resultFuture,
io.vertx.core.Handler<Future<T>> command,
Function<Throwable,T> fallback)
Executes the given operation with the circuit breaker control.
|
<T> void |
CircuitBreaker.executeCommand(io.vertx.core.Handler<Future<T>> command,
io.vertx.core.Handler<io.vertx.core.AsyncResult<T>> handler)
Same as
CircuitBreaker.executeWithFallback(io.vertx.core.Handler<io.vertx.rxjava.core.Future<T>>, java.util.function.Function<java.lang.Throwable, T>) but using the circuit breaker default fallback. |
<T> void |
CircuitBreaker.executeCommandWithFallback(io.vertx.core.Handler<Future<T>> command,
Function<Throwable,T> fallback,
io.vertx.core.Handler<io.vertx.core.AsyncResult<T>> handler)
|
<T> Future<T> |
CircuitBreaker.executeWithFallback(io.vertx.core.Handler<Future<T>> command,
Function<Throwable,T> fallback)
Executes the given operation with the circuit breaker control.
|
<T> rx.Single<T> |
CircuitBreaker.rxExecuteCommand(io.vertx.core.Handler<Future<T>> command)
Same as
CircuitBreaker.executeWithFallback(io.vertx.core.Handler<io.vertx.rxjava.core.Future<T>>, java.util.function.Function<java.lang.Throwable, T>) but using the circuit breaker default fallback. |
<T> rx.Single<T> |
CircuitBreaker.rxExecuteCommandWithFallback(io.vertx.core.Handler<Future<T>> command,
Function<Throwable,T> fallback)
|
Modifier and Type | Method and Description |
---|---|
static Future<io.vertx.core.json.JsonObject> |
ConfigRetriever.getConfigAsFuture(ConfigRetriever retriever)
Same as
ConfigRetriever.getConfig(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonObject>>) , but returning a object. |
Modifier and Type | Class and Description |
---|---|
class |
CompositeFuture
The composite future wraps a list of
futures , it is useful when several futures
needs to be coordinated. |
Modifier and Type | Field and Description |
---|---|
static TypeArg<Future> |
Future.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
<U> Future<U> |
CompositeFuture.compose(Function<CompositeFuture,Future<U>> mapper)
Compose this future with a
mapper function. |
<U> Future<U> |
Future.compose(Function<T,Future<U>> mapper)
Compose this future with a
mapper function. |
<U> Future<U> |
CompositeFuture.compose(io.vertx.core.Handler<CompositeFuture> handler,
Future<U> next)
Compose this future with a provided
next future. |
<U> Future<U> |
Future.compose(io.vertx.core.Handler<T> handler,
Future<U> next)
Compose this future with a provided
next future. |
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.
|
static <T> Future<T> |
Future.future()
Create a future that hasn't completed yet
|
static <T> Future<T> |
Future.future(io.vertx.core.Handler<Future<T>> handler)
Create a future that hasn't completed yet and that is passed to the
handler before it is returned. |
<U> Future<U> |
CompositeFuture.map(Function<CompositeFuture,U> mapper)
Apply a
mapper function on this future. |
<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 . |
<V> Future<V> |
Future.mapEmpty()
Map the result of a future to
null . |
static <T> Future<T> |
Future.newInstance(io.vertx.core.Future arg) |
static <T> Future<T> |
Future.newInstance(io.vertx.core.Future arg,
TypeArg<T> __typeArg_T) |
Future<CompositeFuture> |
CompositeFuture.otherwise(CompositeFuture value)
Map the failure of a future to a specific
value . |
Future<CompositeFuture> |
CompositeFuture.otherwise(Function<Throwable,CompositeFuture> mapper)
Apply a
mapper function on this future. |
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 . |
Future<CompositeFuture> |
CompositeFuture.otherwiseEmpty()
Map the failure of a future to
null . |
Future<T> |
Future.otherwiseEmpty()
Map the failure of a future to
null . |
Future<CompositeFuture> |
CompositeFuture.recover(Function<Throwable,Future<CompositeFuture>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
Future<T> |
Future.recover(Function<Throwable,Future<T>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
Future<T> |
Future.setHandler(io.vertx.core.Handler<io.vertx.core.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.
|
Modifier and Type | Method and Description |
---|---|
static CompositeFuture |
CompositeFuture.all(List<Future> futures)
Like
CompositeFuture.all(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>) but with a list of futures. |
static CompositeFuture |
CompositeFuture.any(List<Future> futures)
Like
CompositeFuture.any(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>) but with a list of futures. |
<U> Future<U> |
CompositeFuture.compose(Function<CompositeFuture,Future<U>> mapper)
Compose this future with a
mapper function. |
<U> Future<U> |
Future.compose(Function<T,Future<U>> mapper)
Compose this future with a
mapper function. |
<T> void |
Vertx.executeBlocking(io.vertx.core.Handler<Future<T>> blockingCodeHandler,
boolean ordered,
io.vertx.core.Handler<io.vertx.core.AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
WorkerExecutor.executeBlocking(io.vertx.core.Handler<Future<T>> blockingCodeHandler,
boolean ordered,
io.vertx.core.Handler<io.vertx.core.AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
Context.executeBlocking(io.vertx.core.Handler<Future<T>> blockingCodeHandler,
boolean ordered,
io.vertx.core.Handler<io.vertx.core.AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
Vertx.executeBlocking(io.vertx.core.Handler<Future<T>> blockingCodeHandler,
io.vertx.core.Handler<io.vertx.core.AsyncResult<T>> resultHandler)
|
<T> void |
WorkerExecutor.executeBlocking(io.vertx.core.Handler<Future<T>> blockingCodeHandler,
io.vertx.core.Handler<io.vertx.core.AsyncResult<T>> resultHandler)
|
<T> void |
Context.executeBlocking(io.vertx.core.Handler<Future<T>> blockingCodeHandler,
io.vertx.core.Handler<io.vertx.core.AsyncResult<T>> resultHandler)
|
<T> rx.Observable<T> |
Vertx.executeBlockingObservable(io.vertx.core.Handler<Future<T>> blockingCodeHandler)
Deprecated.
|
<T> rx.Observable<T> |
WorkerExecutor.executeBlockingObservable(io.vertx.core.Handler<Future<T>> blockingCodeHandler)
Deprecated.
|
<T> rx.Observable<T> |
Context.executeBlockingObservable(io.vertx.core.Handler<Future<T>> blockingCodeHandler)
Deprecated.
|
<T> rx.Observable<T> |
Vertx.executeBlockingObservable(io.vertx.core.Handler<Future<T>> blockingCodeHandler,
boolean ordered)
Deprecated.
|
<T> rx.Observable<T> |
WorkerExecutor.executeBlockingObservable(io.vertx.core.Handler<Future<T>> blockingCodeHandler,
boolean ordered)
Deprecated.
|
<T> rx.Observable<T> |
Context.executeBlockingObservable(io.vertx.core.Handler<Future<T>> blockingCodeHandler,
boolean ordered)
Deprecated.
|
static <T> Future<T> |
Future.future(io.vertx.core.Handler<Future<T>> handler)
Create a future that hasn't completed yet and that is passed to the
handler before it is returned. |
static CompositeFuture |
CompositeFuture.join(List<Future> futures)
Like
CompositeFuture.join(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>) but with a list of futures. |
Future<CompositeFuture> |
CompositeFuture.recover(Function<Throwable,Future<CompositeFuture>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
Future<T> |
Future.recover(Function<Throwable,Future<T>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
<T> rx.Single<T> |
Vertx.rxExecuteBlocking(io.vertx.core.Handler<Future<T>> blockingCodeHandler)
|
<T> rx.Single<T> |
WorkerExecutor.rxExecuteBlocking(io.vertx.core.Handler<Future<T>> blockingCodeHandler)
|
<T> rx.Single<T> |
Context.rxExecuteBlocking(io.vertx.core.Handler<Future<T>> blockingCodeHandler)
|
<T> rx.Single<T> |
Vertx.rxExecuteBlocking(io.vertx.core.Handler<Future<T>> blockingCodeHandler,
boolean ordered)
Safely execute some blocking code.
|
<T> rx.Single<T> |
WorkerExecutor.rxExecuteBlocking(io.vertx.core.Handler<Future<T>> blockingCodeHandler,
boolean ordered)
Safely execute some blocking code.
|
<T> rx.Single<T> |
Context.rxExecuteBlocking(io.vertx.core.Handler<Future<T>> blockingCodeHandler,
boolean ordered)
Safely execute some blocking code.
|
Modifier and Type | Method and Description |
---|---|
void |
ServerWebSocket.setHandshake(Future<Integer> future)
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 status code
rejected when the future is succeeds with an HTTP status code different than
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(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) method
will try to accept the handshake and close the WebSocket afterward. |
Modifier and Type | Method and Description |
---|---|
HttpClient |
HttpClient.redirectHandler(Function<HttpClientResponse,Future<HttpClientRequest>> handler)
Set a redirect handler for the http client.
|
Modifier and Type | Class and Description |
---|---|
class |
BaseBridgeEvent
Represents an event that occurs on the event bus bridge.
|
Modifier and Type | Method and Description |
---|---|
<U> Future<U> |
BaseBridgeEvent.compose(Function<Boolean,Future<U>> mapper)
Compose this future with a
mapper function. |
<U> Future<U> |
BaseBridgeEvent.compose(io.vertx.core.Handler<Boolean> handler,
Future<U> next)
Compose this future with a provided
next future. |
<U> Future<U> |
BaseBridgeEvent.map(Function<Boolean,U> mapper)
Apply a
mapper function on this future. |
Future<Boolean> |
BaseBridgeEvent.otherwise(Boolean value)
Map the failure of a future to a specific
value . |
Future<Boolean> |
BaseBridgeEvent.otherwise(Function<Throwable,Boolean> mapper)
Apply a
mapper function on this future. |
Future<Boolean> |
BaseBridgeEvent.otherwiseEmpty()
Map the failure of a future to
null . |
Future<Boolean> |
BaseBridgeEvent.recover(Function<Throwable,Future<Boolean>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
Future<Boolean> |
BaseBridgeEvent.setHandler(io.vertx.core.Handler<io.vertx.core.AsyncResult<Boolean>> handler)
Set a handler for the result.
|
Modifier and Type | Method and Description |
---|---|
<U> Future<U> |
BaseBridgeEvent.compose(io.vertx.core.Handler<Boolean> handler,
Future<U> next)
Compose this future with a provided
next future. |
Modifier and Type | Method and Description |
---|---|
<U> Future<U> |
BaseBridgeEvent.compose(Function<Boolean,Future<U>> mapper)
Compose this future with a
mapper function. |
Future<Boolean> |
BaseBridgeEvent.recover(Function<Throwable,Future<Boolean>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
Modifier and Type | Method and Description |
---|---|
<U> Future<U> |
BridgeEvent.compose(Function<Boolean,Future<U>> mapper)
Compose this future with a
mapper function. |
<U> Future<U> |
BridgeEvent.compose(io.vertx.core.Handler<Boolean> handler,
Future<U> next)
Compose this future with a provided
next future. |
<U> Future<U> |
BridgeEvent.map(Function<Boolean,U> mapper)
Apply a
mapper function on this future. |
Future<Boolean> |
BridgeEvent.otherwise(Boolean value)
Map the failure of a future to a specific
value . |
Future<Boolean> |
BridgeEvent.otherwise(Function<Throwable,Boolean> mapper)
Apply a
mapper function on this future. |
Future<Boolean> |
BridgeEvent.otherwiseEmpty()
Map the failure of a future to
null . |
Future<Boolean> |
BridgeEvent.recover(Function<Throwable,Future<Boolean>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
Future<Boolean> |
BridgeEvent.setHandler(io.vertx.core.Handler<io.vertx.core.AsyncResult<Boolean>> handler)
Set a handler for the result.
|
Modifier and Type | Method and Description |
---|---|
<U> Future<U> |
BridgeEvent.compose(io.vertx.core.Handler<Boolean> handler,
Future<U> next)
Compose this future with a provided
next future. |
Modifier and Type | Method and Description |
---|---|
<U> Future<U> |
BridgeEvent.compose(Function<Boolean,Future<U>> mapper)
Compose this future with a
mapper function. |
Future<Boolean> |
BridgeEvent.recover(Function<Throwable,Future<Boolean>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
Modifier and Type | Method and Description |
---|---|
HealthCheckHandler |
HealthCheckHandler.register(String name,
io.vertx.core.Handler<Future<io.vertx.ext.healthchecks.Status>> procedure)
Registers a health check procedure.
|
HealthChecks |
HealthChecks.register(String name,
io.vertx.core.Handler<Future<io.vertx.ext.healthchecks.Status>> procedure)
Registers a health check procedure.
|
HealthCheckHandler |
HealthCheckHandler.register(String name,
long timeout,
io.vertx.core.Handler<Future<io.vertx.ext.healthchecks.Status>> procedure)
Registers a health check procedure.
|
HealthChecks |
HealthChecks.register(String name,
long timeout,
io.vertx.core.Handler<Future<io.vertx.ext.healthchecks.Status>> procedure)
Registers a health check procedure.
|
Modifier and Type | Method and Description |
---|---|
void |
Completion.resolve(Future<T> future)
Completes the future upon completion, otherwise fails it.
|
void |
TestCompletion.resolve(Future<Void> future)
Completes the future upon completion, otherwise fails it.
|
void |
Async.resolve(Future<Void> future)
Completes the future upon completion, otherwise fails it.
|
Modifier and Type | Class and Description |
---|---|
class |
BridgeEvent
Represents an event that occurs on the event bus bridge.
|
Modifier and Type | Method and Description |
---|---|
<U> Future<U> |
BridgeEvent.compose(Function<Boolean,Future<U>> mapper)
Compose this future with a
mapper function. |
<U> Future<U> |
BridgeEvent.compose(io.vertx.core.Handler<Boolean> handler,
Future<U> next)
Compose this future with a provided
next future. |
<U> Future<U> |
BridgeEvent.map(Function<Boolean,U> mapper)
Apply a
mapper function on this future. |
Future<Boolean> |
BridgeEvent.otherwise(Boolean value)
Map the failure of a future to a specific
value . |
Future<Boolean> |
BridgeEvent.otherwise(Function<Throwable,Boolean> mapper)
Apply a
mapper function on this future. |
Future<Boolean> |
BridgeEvent.otherwiseEmpty()
Map the failure of a future to
null . |
Future<Boolean> |
BridgeEvent.recover(Function<Throwable,Future<Boolean>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
Future<Boolean> |
BridgeEvent.setHandler(io.vertx.core.Handler<io.vertx.core.AsyncResult<Boolean>> handler)
Set a handler for the result.
|
Modifier and Type | Method and Description |
---|---|
<U> Future<U> |
BridgeEvent.compose(io.vertx.core.Handler<Boolean> handler,
Future<U> next)
Compose this future with a provided
next future. |
Modifier and Type | Method and Description |
---|---|
<U> Future<U> |
BridgeEvent.compose(Function<Boolean,Future<U>> mapper)
Compose this future with a
mapper function. |
Future<Boolean> |
BridgeEvent.recover(Function<Throwable,Future<Boolean>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceExporter.init(Vertx vertx,
ServicePublisher publisher,
io.vertx.core.json.JsonObject configuration,
Future<Void> future)
Starts the exporter.
|
void |
ServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
io.vertx.core.json.JsonObject configuration,
Future<Void> future)
Starts the importer.
|
Copyright © 2019 Eclipse. All rights reserved.