public class ReactiveActor extends AbstractLoopingActor
final def doubler = reactor {message ->
2 * message
}
def result = doubler.sendAndWait(10)
Actor.MyRemoteHandle, Actor.RemoteActorMessageStream.RemoteMessageStream, MessageStream.SendTo| Modifier and Type | Field and Description |
|---|---|
private static long |
serialVersionUID |
terminatingFlagACTOR_HAS_ALREADY_BEEN_STARTED, CANNOT_SEND_REPLIES_NO_SENDER_HAS_BEEN_REGISTERED, currentThread, parallelGroup, START_MESSAGE, STOP_MESSAGE, TERMINATE_MESSAGE, TIMEOUT, TIMEOUT_MESSAGE, timerserialHandle| Constructor and Description |
|---|
ReactiveActor(groovy.lang.Closure body) |
getCore, getSender, hasBeenStopped, initialize, isActive, isFair, makeFair, reply, replyIfExists, send, setParallelGroup, setTimeout, silentStart, start, stop, sweepNextMessage, terminatecreateActorMessage, createRemoteHandle, deregisterCurrentActorWithThread, getJoinLatch, getParallelGroup, handleException, handleInterrupt, handleStart, handleTermination, handleTimeout, isActorThread, join, join, join, join, onStop, registerCurrentActorWithThread, sendAndContinue, sendAndPromise, sweepQueue, threadBoundActorcall, getRemoteClass, leftShift, send, send, sendAndWait, sendAndWait, sendAndWaitgetOrCreateSerialHandle, writeReplaceprivate static final long serialVersionUID