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
Throwable
protected void setReceivers(int receivers)
public EventReply waitFor() throws Throwable
Throwable
public EventReply waitFor(long l) throws Throwable
Throwable
public Object get() throws InterruptedException, ExecutionException
get
in interface Future<Object>
InterruptedException
ExecutionException
public Object get(long l, TimeUnit timeUnit) throws InterruptedException, ExecutionException, TimeoutException
get
in interface Future<Object>
InterruptedException
ExecutionException
TimeoutException