public class Completion<T> extends Object
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<Completion> |
__TYPE_ARG |
io.vertx.lang.rx.TypeArg<T> |
__typeArg_0 |
Constructor and Description |
---|
Completion(Completion delegate) |
Completion(Object delegate,
io.vertx.lang.rx.TypeArg<T> typeArg_0) |
Modifier and Type | Method and Description |
---|---|
void |
await()
Cause the current thread to wait until this completion completes.
If the current thread is interrupted, an exception will be thrown.
|
void |
await(long timeoutMillis)
Cause the current thread to wait until this completion completes with a configurable timeout.
If completion times out or the current thread is interrupted, an exception will be thrown.
|
void |
awaitSuccess()
Cause the current thread to wait until this completion completes and succeeds.
If the current thread is interrupted or the suite fails, an exception will be thrown.
|
void |
awaitSuccess(long timeoutMillis)
Cause the current thread to wait until this completion completes and succeeds with a configurable timeout.
If completion times out or the current thread is interrupted or the suite fails, an exception will be thrown.
|
boolean |
equals(Object o) |
Completion |
getDelegate() |
void |
handler()
Completion handler to receive a completion signal when this completions completes.
|
void |
handler(Handler<AsyncResult<T>> completionHandler)
Completion handler to receive a completion signal when this completions completes.
|
int |
hashCode() |
boolean |
isCompleted() |
boolean |
isFailed() |
boolean |
isSucceeded() |
static <T> Completion<T> |
newInstance(Completion arg) |
static <T> Completion<T> |
newInstance(Completion arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
void |
resolve(Promise<T> future)
Completes the future upon completion, otherwise fails it.
|
Maybe<T> |
rxHandler()
Completion handler to receive a completion signal when this completions completes.
|
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<Completion> __TYPE_ARG
public final io.vertx.lang.rx.TypeArg<T> __typeArg_0
public Completion(Completion delegate)
public Completion getDelegate()
public void resolve(Promise<T> future)
future
- the future to resolvepublic boolean isCompleted()
public boolean isSucceeded()
public boolean isFailed()
public void handler(Handler<AsyncResult<T>> completionHandler)
completionHandler
- the completion handlerpublic void handler()
public Maybe<T> rxHandler()
public void await()
public void await(long timeoutMillis)
timeoutMillis
- the timeout in millisecondspublic void awaitSuccess()
public void awaitSuccess(long timeoutMillis)
timeoutMillis
- the timeout in millisecondspublic static <T> Completion<T> newInstance(Completion arg)
public static <T> Completion<T> newInstance(Completion arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)
Copyright © 2024 Eclipse. All rights reserved.