|
Groovy Documentation | |||||||
FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectgroovyx.gpars.serial.WithSerialId
gpars.actor.impl.MessageStream
gpars.actor.impl.MessageStream.ResultWaiter
class MessageStream.ResultWaiter extends MessageStream
Represents a pending request for a reply from an actor.
Constructor Summary | |
private MessageStream.ResultWaiter()
|
Method Summary | |
---|---|
V
|
getResult()
Retrieves the response blocking until a message arrives |
Object
|
getResult(long timeout, TimeUnit units)
Retrieves the response blocking until a message arrives |
void
|
onDeliveryError()
Handle cases when the message sent to the actor doesn't get delivered |
MessageStream
|
send(Object message)
Accepts the message as a reply and wakes up the sleeping thread. |
Methods inherited from class MessageStream | |
---|---|
call, getRemoteClass, leftShift, reInterrupt, send, send, send, sendAndContinue, sendAndWait, sendAndWait, sendAndWait |
Constructor Detail |
---|
private MessageStream.ResultWaiter()
Method Detail |
---|
public V getResult()
public Object getResult(long timeout, TimeUnit units)
public void onDeliveryError()
@Override public MessageStream send(Object message)
Groovy Documentation