|
Groovy Documentation | |||||||
FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectgroovyx.gpars.serial.WithSerialId
gpars.actor.impl.MessageStream
class MessageStream extends WithSerialId
Stream of abstract messages
Nested Class Summary | |
---|---|
class |
MessageStream.RemoteMessageStream
|
class |
MessageStream.ResultWaiter
Represents a pending request for a reply from an actor. |
class |
MessageStream.SendTo
|
Constructor Summary | |
MessageStream()
|
Method Summary | |
---|---|
MessageStream
|
call(T message)
Same as send |
Class
|
getRemoteClass()
|
MessageStream
|
leftShift(T message)
Same as send |
static void
|
reInterrupt()
|
MessageStream
|
send(Object message)
Send message to stream and return immediately |
MessageStream
|
send()
Convenience method for send(new Object()). |
MessageStream
|
send(T message, MessageStream replyTo)
Send message to stream and return immediately. |
MessageStream
|
sendAndContinue(T message, Closure closure)
Sends a message and execute continuation when reply became available. |
V
|
sendAndWait(T message)
Sends a message and waits for a reply. |
Object
|
sendAndWait(T message, long timeout, TimeUnit units)
Sends a message and waits for a reply. |
Object
|
sendAndWait(T message, Duration duration)
Sends a message and waits for a reply. |
Constructor Detail |
---|
MessageStream()
Method Detail |
---|
public final MessageStream call(T message)
@Override public Class getRemoteClass()
public final MessageStream leftShift(T message)
public static void reInterrupt()
public MessageStream send(Object message)
public MessageStream send()
public final MessageStream send(T message, MessageStream replyTo)
@SuppressWarnings({"AssignmentToMethodParameter"}) public final MessageStream sendAndContinue(T message, Closure closure)
public final V sendAndWait(T message)
public final Object sendAndWait(T message, long timeout, TimeUnit units)
public final Object sendAndWait(T message, Duration duration)
Groovy Documentation