Modifier and Type | Method and Description |
---|---|
<T> CircuitBreaker |
CircuitBreaker.executeAndReport(Promise<T> resultPromise,
Handler<Promise<T>> command)
Same as
CircuitBreaker.executeAndReportWithFallback(io.vertx.reactivex.core.Promise<T>, io.vertx.core.Handler<io.vertx.reactivex.core.Promise<T>>, java.util.function.Function<java.lang.Throwable, T>) but using the circuit breaker default
fallback. |
<T> CircuitBreaker |
CircuitBreaker.executeAndReportWithFallback(Promise<T> resultPromise,
Handler<Promise<T>> command,
java.util.function.Function<Throwable,T> fallback)
Executes the given operation with the circuit breaker control.
|
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<Promise> |
Promise.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
static <T> Promise<T> |
Promise.newInstance(Promise arg) |
static <T> Promise<T> |
Promise.newInstance(Promise arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
static <T> Promise<T> |
Promise.promise()
Create a promise that hasn't completed yet
|
Modifier and Type | Method and Description |
---|---|
<T> void |
Context.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered,
Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
Vertx.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered,
Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
WorkerExecutor.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered,
Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
Context.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
Handler<AsyncResult<T>> resultHandler)
|
<T> void |
Vertx.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
Handler<AsyncResult<T>> resultHandler)
|
<T> void |
WorkerExecutor.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
Handler<AsyncResult<T>> resultHandler)
|
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. |
<T> Maybe<T> |
Context.rxExecuteBlocking(Handler<Promise<T>> blockingCodeHandler)
|
<T> Maybe<T> |
Vertx.rxExecuteBlocking(Handler<Promise<T>> blockingCodeHandler)
|
<T> Maybe<T> |
WorkerExecutor.rxExecuteBlocking(Handler<Promise<T>> blockingCodeHandler)
|
<T> Maybe<T> |
Context.rxExecuteBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered)
Safely execute some blocking code.
|
<T> Maybe<T> |
Vertx.rxExecuteBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered)
Safely execute some blocking code.
|
<T> Maybe<T> |
WorkerExecutor.rxExecuteBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered)
Safely execute some blocking code.
|
Modifier and Type | Class and Description |
---|---|
class |
BaseBridgeEvent
Represents an event that occurs on the event bus bridge.
|
Modifier and Type | Class and Description |
---|---|
class |
BridgeEvent
Represents an event that occurs on the event bus bridge.
|
Modifier and Type | Method and Description |
---|---|
HealthChecks |
HealthChecks.register(String name,
Handler<Promise<Status>> procedure)
Registers a health check procedure.
|
HealthCheckHandler |
HealthCheckHandler.register(String name,
Handler<Promise<Status>> procedure)
Registers a health check procedure.
|
HealthChecks |
HealthChecks.register(String name,
long timeout,
Handler<Promise<Status>> procedure)
Registers a health check procedure.
|
HealthCheckHandler |
HealthCheckHandler.register(String name,
long timeout,
Handler<Promise<Status>> procedure)
Registers a health check procedure.
|
Modifier and Type | Method and Description |
---|---|
void |
Completion.resolve(Promise<T> future)
Completes the future upon completion, otherwise fails it.
|
void |
Async.resolve(Promise<Void> future)
Completes the future upon completion, otherwise fails it.
|
void |
TestCompletion.resolve(Promise<Void> future)
Completes the future upon completion, otherwise fails it.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceExporter.init(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> future)
Starts the exporter.
|
void |
ServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> future)
Starts the importer.
|
Copyright © 2023 Eclipse. All rights reserved.