public class EventReply extends Object implements Serializable, Future<Object>
| Constructor and Description |
|---|
EventReply(Future<?> future,
int receivers) |
EventReply(Object val,
int receivers) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
addValue(Object v) |
boolean |
cancel() |
boolean |
cancel(boolean b) |
Object |
get() |
Object |
get(long l,
TimeUnit timeUnit) |
List<Throwable> |
getErrors() |
groovy.lang.Closure |
getOnError() |
Object |
getValue() |
List<Object> |
getValues() |
boolean |
hasErrors() |
protected void |
initValues(Object val) |
boolean |
isCancelled() |
boolean |
isDone() |
boolean |
isSuccess() |
void |
setOnError(groovy.lang.Closure onError) |
protected void |
setReceivers(int receivers) |
int |
size() |
void |
throwError() |
EventReply |
waitFor() |
EventReply |
waitFor(long l) |
public EventReply(Object val, int receivers)
public EventReply(Future<?> future, int receivers)
public void setOnError(groovy.lang.Closure onError)
public groovy.lang.Closure getOnError()
protected void initValues(Object val)
public boolean cancel()
public boolean isCancelled()
isCancelled in interface Future<Object>public boolean isSuccess()
public boolean hasErrors()
public void throwError() throws Throwable
Throwableprotected void setReceivers(int receivers)
public EventReply waitFor() throws Throwable
Throwablepublic EventReply waitFor(long l) throws Throwable
Throwablepublic Object get() throws InterruptedException, ExecutionException
get in interface Future<Object>InterruptedExceptionExecutionExceptionpublic Object get(long l, TimeUnit timeUnit) throws InterruptedException, ExecutionException, TimeoutException
get in interface Future<Object>InterruptedExceptionExecutionExceptionTimeoutException