Overview  Package   Class  Deprecated  Index  Help 
Groovy Documentation
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

gpars.actor.impl
Class SequentialProcessingActor.Reaction

java.lang.Object
  gpars.actor.impl.SequentialProcessingActor.Reaction

@SuppressWarnings({"InstanceVariableOfConcreteClass"})
class SequentialProcessingActor.Reaction

Buffers messages for the next continuation of an event-driven actor, handles timeouts and no-param continuations.

author:
Vaclav Pech, Alex Tkachman Date: May 22, 2009

Constructor Summary
SequentialProcessingActor.Reaction(SequentialProcessingActor actor, boolean codeNeedsArgument, Closure code)

Creates a new instance.

 
Method Summary
boolean isReady()

Indicates whether a message or a timeout has arrived.

void offer(ActorMessage actorMessage)

void setTimeout(long timeout)

 
Methods inherited from class Object
wait, wait, wait, equals, toString, hashCode, getClass, notify, notifyAll
 

Constructor Detail

SequentialProcessingActor.Reaction

public SequentialProcessingActor.Reaction(SequentialProcessingActor actor, boolean codeNeedsArgument, Closure code)
Creates a new instance.
param:
actor actor
param:
codeNeedsArgument Indicates, whether the provided code expects an argument
param:
code code to execute

 
Method Detail

isReady

@SuppressWarnings({"BooleanMethodIsAlwaysInverted"})
public boolean isReady()
Indicates whether a message or a timeout has arrived.
return:
True, if the next continuation can start.

offer

public void offer(ActorMessage actorMessage)

setTimeout

public void setTimeout(long timeout)

 

Groovy Documentation