Package | Description |
---|---|
io.vertx.rxjava.circuitbreaker | |
io.vertx.rxjava.core | |
io.vertx.rxjava.ext.unit | |
io.vertx.rxjava.ext.web.handler.sockjs | |
io.vertx.rxjava.servicediscovery.spi |
Modifier and Type | Method and Description |
---|---|
<T> Future<T> |
CircuitBreaker.execute(Handler<Future<T>> operation)
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(Handler<Future<T>> operation,
java.util.function.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,
Handler<Future<T>> operation)
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,
Handler<Future<T>> operation,
java.util.function.Function<Throwable,T> fallback)
Executes the given operation with the circuit breaker control.
|
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 | Method and Description |
---|---|
<U> Future<U> |
Future.compose(java.util.function.Function<T,Future<U>> mapper)
Compose this future with a
mapper function. |
<U> Future<U> |
Future.compose(Handler<T> handler,
Future<U> composed)
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.future()
Create a future that hasn't completed yet
|
<U> Future<U> |
Future.map(java.util.function.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 . |
static <T> Future |
Future.newInstance(Future arg) |
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.
|
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> |
Future.compose(java.util.function.Function<T,Future<U>> mapper)
Compose this future with a
mapper function. |
<T> void |
Context.executeBlocking(Handler<Future<T>> blockingCodeHandler,
boolean ordered,
Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
Vertx.executeBlocking(Handler<Future<T>> blockingCodeHandler,
boolean ordered,
Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
WorkerExecutor.executeBlocking(Handler<Future<T>> blockingCodeHandler,
boolean ordered,
Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
Context.executeBlocking(Handler<Future<T>> blockingCodeHandler,
Handler<AsyncResult<T>> resultHandler)
|
<T> void |
Vertx.executeBlocking(Handler<Future<T>> blockingCodeHandler,
Handler<AsyncResult<T>> resultHandler)
|
<T> void |
WorkerExecutor.executeBlocking(Handler<Future<T>> blockingCodeHandler,
Handler<AsyncResult<T>> resultHandler)
|
<T> Observable<T> |
Context.executeBlockingObservable(Handler<Future<T>> blockingCodeHandler)
|
<T> Observable<T> |
Vertx.executeBlockingObservable(Handler<Future<T>> blockingCodeHandler)
|
<T> Observable<T> |
WorkerExecutor.executeBlockingObservable(Handler<Future<T>> blockingCodeHandler)
|
<T> Observable<T> |
Context.executeBlockingObservable(Handler<Future<T>> blockingCodeHandler,
boolean ordered)
Safely execute some blocking code.
|
<T> Observable<T> |
Vertx.executeBlockingObservable(Handler<Future<T>> blockingCodeHandler,
boolean ordered)
Safely execute some blocking code.
|
<T> Observable<T> |
WorkerExecutor.executeBlockingObservable(Handler<Future<T>> blockingCodeHandler,
boolean ordered)
Safely execute some blocking code.
|
Modifier and Type | Method and Description |
---|---|
void |
Completion.resolve(Future<T> 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 |
---|---|
void |
ServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Future<Void> future)
Starts the bridge.
|
void |
ServiceImporter.stop(Vertx vertx,
ServicePublisher publisher,
Future<Void> future)
Stops the bridge.
|
Copyright © 2016. All rights reserved.