|
Groovy Documentation | |||||||
FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectgroovyx.gpars.serial.WithSerialId
gpars.actor.impl.MessageStream
public abstract class MessageStream extends WithSerialId
Stream of abstract messages
Nested Class Summary | |
---|---|
static class |
MessageStream.RemoteMessageStream
|
static class |
MessageStream.SendTo
|
Method Summary | |
---|---|
MessageStream
|
call(Object message)
Same as send |
Class
|
getRemoteClass()
|
MessageStream
|
leftShift(Object message)
Same as send |
MessageStream
|
send(Object message)
Send message to stream and return immediately |
MessageStream
|
send()
Convenience method for send(new Object()). |
MessageStream
|
send(Object message, MessageStream replyTo)
Send message to stream and return immediately. |
MessageStream
|
sendAndContinue(Object message, groovy.lang.Closure closure)
Sends a message and execute continuation when reply became available. |
Object
|
sendAndWait(Object message)
Sends a message and waits for a reply. |
Object
|
sendAndWait(Object message, long timeout, TimeUnit units)
Sends a message and waits for a reply. |
Object
|
sendAndWait(Object message, groovy.time.Duration duration)
Sends a message and waits for a reply. |
Method Detail |
---|
public final MessageStream call(Object message)
message
- to send
@Override public Class getRemoteClass()
public final MessageStream leftShift(Object message)
message
- to send
public MessageStream send(Object message)
message
- message to send
public MessageStream send()
public final MessageStream send(Object message, MessageStream replyTo)
message
- message to sendreplyTo
- where to send reply
- type of message accepted by the stream
@SuppressWarnings({"AssignmentToMethodParameter"}) public final MessageStream sendAndContinue(Object message, groovy.lang.Closure closure)
message
- message to sendclosure
- closure to execute when reply became available
public final Object sendAndWait(Object message)
message
- message to send
public final Object sendAndWait(Object message, long timeout, TimeUnit units)
message
- message to sendtimeout
- timeoutunits
- units
public final Object sendAndWait(Object message, groovy.time.Duration duration)
message
- message to sendduration
- timeout
Groovy Documentation