Uses of Class
groovyx.gpars.actor.impl.MessageStream

Packages that use MessageStream

Package	Description
groovyx.gpars.activeobject
groovyx.gpars.actor	This package holds classes forming the public actor API.
groovyx.gpars.actor.impl	This package holds classes some non-public aspects of actor implementation.
groovyx.gpars.dataflow	This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
groovyx.gpars.dataflow.expression
groovyx.gpars.dataflow.operator	This package holds classes representing operators and channels necessary for full dataflow concurrency.
groovyx.gpars.dataflow.stream

Uses of MessageStream in groovyx.gpars.activeobject

Subclasses of MessageStream in groovyx.gpars.activeobject

Modifier and Type	Class and Description
class	InternalActor Backs active objects and invokes all object's active methods.

Uses of MessageStream in groovyx.gpars.actor

Subclasses of MessageStream in groovyx.gpars.actor

Modifier and Type	Class and Description
class	AbstractLoopingActor Wraps all actors that repeatedly loop through incoming messages and hold no implicit state between subsequent messages.
class	Actor Actors are active objects, which borrow a thread from a thread pool.
static class	Actor.RemoteActor
class	BlockingActor
class	DefaultActor The DefaultActor class is the base for all stateful actors, who need to maintain implicit state between subsequent message arrivals.
class	DynamicDispatchActor A pooled actor allowing for an alternative structure of the message handling code.
class	ReactiveActor An actor representing a reactor.
class	StaticDispatchActor<T> Offers a statically dispatched and thus slightly faster alternative to the DynamicDispatchActor class.

Fields in groovyx.gpars.actor declared as MessageStream

Modifier and Type	Field and Description
private MessageStream	AbstractLoopingActor.currentSender
private MessageStream	ActorMessage.sender

Methods in groovyx.gpars.actor that return MessageStream

Modifier and Type	Method and Description
MessageStream	AbstractLoopingActor.getSender() Retrieves the sender actor of the currently processed message.
MessageStream	ActorMessage.getSender()
MessageStream	AbstractLoopingActor.send(java.lang.Object message)
MessageStream	Actor.RemoteActor.send(java.lang.Object message)
<T> MessageStream	Actor.sendAndContinue(T message, groovy.lang.Closure closure) Sends a message and execute continuation when reply became available.

Methods in groovyx.gpars.actor with parameters of type MessageStream

Modifier and Type	Method and Description
void	Actor.join(MessageStream listener) Notify listener when finished

Constructors in groovyx.gpars.actor with parameters of type MessageStream

Constructor and Description
ActorMessage(java.lang.Object payLoad, MessageStream sender) Creates a new instance

Uses of MessageStream in groovyx.gpars.actor.impl

Subclasses of MessageStream in groovyx.gpars.actor.impl

Modifier and Type	Class and Description
static class	MessageStream.RemoteMessageStream
private static class	MessageStream.ResultWaiter<V> Represents a pending request for a reply from an actor.
class	ReplyingMessageStream
class	RunnableBackedBlockingActor Utility class to implement a blocking actor backed by any Runnable (including Closure)
class	SequentialProcessingActor

Fields in groovyx.gpars.actor.impl declared as MessageStream

Modifier and Type	Field and Description
private MessageStream	ReplyingMessageStream.sender A list of senders for the currently processed messages
private MessageStream	MessageStream.SendTo.to

Methods in groovyx.gpars.actor.impl that return MessageStream

Modifier and Type	Method and Description
<T> MessageStream	MessageStream.call(T message) Same as send
protected MessageStream	ReplyingMessageStream.getSender()
MessageStream	MessageStream.SendTo.getTo()
<T> MessageStream	MessageStream.leftShift(T message) Same as send
MessageStream	MessageStream.send() Convenience method for send(new Object()).
abstract MessageStream	MessageStream.send(java.lang.Object message) Send message to stream and return immediately
MessageStream	MessageStream.ResultWaiter.send(java.lang.Object message) Accepts the message as a reply and wakes up the sleeping thread.
MessageStream	MessageStream.RemoteMessageStream.send(java.lang.Object message)
MessageStream	SequentialProcessingActor.send(java.lang.Object message)
<T> MessageStream	MessageStream.send(T message, MessageStream replyTo) Send message to stream and return immediately.

Methods in groovyx.gpars.actor.impl with parameters of type MessageStream

Modifier and Type	Method and Description
<T> MessageStream	MessageStream.send(T message, MessageStream replyTo) Send message to stream and return immediately.
protected void	ReplyingMessageStream.setSender(MessageStream sender)

Constructors in groovyx.gpars.actor.impl with parameters of type MessageStream

Constructor and Description
MessageStream.SendTo(MessageStream to, ActorMessage message)

Uses of MessageStream in groovyx.gpars.dataflow

Subclasses of MessageStream in groovyx.gpars.dataflow

Modifier and Type	Class and Description
class	DataCallback A helper class enabling the 'whenBound()' or 'getValAsync' functionality of a DataflowVariable and DataflowQueue, as well as 'sendAndContinue()' on actors.
class	DataCallbackWithPool A helper class enabling the 'whenBound()' or 'getValAsync' functionality of a DataflowVariable and DataflowQueue, whenever a thread pool instead of a PGroup is specified..

Fields in groovyx.gpars.dataflow with type parameters of type MessageStream

Modifier and Type	Field and Description
private java.util.Collection<MessageStream>	DataflowQueue.wheneverBoundListeners A collection of listeners who need to be informed each time the stream is bound to a value

Methods in groovyx.gpars.dataflow that return MessageStream

Modifier and Type	Method and Description
MessageStream	DataCallback.send(java.lang.Object message) Sends a message back to the DataCallback.
MessageStream	DataCallbackWithPool.send(java.lang.Object message) Sends a message back to the DataCallback.

Methods in groovyx.gpars.dataflow with parameters of type MessageStream

Modifier and Type	Method and Description
void	Select.call(MessageStream messageStream) Selects a value from a single randomly chosen input channel, which has a value available for read.
void	Select.call(MessageStream messageStream, java.util.List<java.lang.Boolean> mask) Selects a value from a single randomly chosen input channel, which has a value available for read.
void	DataflowQueue.getValAsync(MessageStream callback) Asynchronously retrieves the value at the head of the buffer.
void	DataflowReadChannel.getValAsync(MessageStream callback) Asynchronously retrieves the value from the channel.
void	LazyDataflowVariable.getValAsync(MessageStream callback)
void	SyncDataflowStreamReadAdapter.getValAsync(MessageStream callback)
void	DataflowQueue.getValAsync(java.lang.Object attachment, MessageStream callback) Asynchronously retrieves the value at the head of the buffer.
void	DataflowReadChannel.getValAsync(java.lang.Object attachment, MessageStream callback) Asynchronously retrieves the value from the channel.
void	LazyDataflowVariable.getValAsync(java.lang.Object attachment, MessageStream callback)
void	SyncDataflowStreamReadAdapter.getValAsync(java.lang.Object attachment, MessageStream callback)
void	Select.prioritySelect(MessageStream messageStream) Selects a value from a single input channel, which has a value available for read.
void	Select.prioritySelect(MessageStream messageStream, java.util.List<java.lang.Boolean> mask) Selects a value from a single input channel, which has a value available for read.
protected void	SyncDataflowVariable.scheduleCallback(java.lang.Object attachment, MessageStream callback)
void	Select.select(MessageStream messageStream) Selects a value from a single randomly chosen input channel, which has a value available for read.
private void	Select.select(MessageStream messageStream, int startIndex, java.util.List<java.lang.Boolean> mask) Invokes the internal select base with a SelectRequest instance ensuring a message is sent, once a value has been selected
void	Select.select(MessageStream messageStream, java.util.List<java.lang.Boolean> mask) Selects a value from a single randomly chosen input channel, which has a value available for read.
void	DataflowQueue.whenBound(MessageStream stream) Send the next bound piece of data to the provided stream when it becomes available.
void	DataflowReadChannel.whenBound(MessageStream stream) Send the bound data to provided stream when it becomes available
void	Promise.whenBound(MessageStream stream) Send the bound data to provided stream when it becomes available
void	SyncDataflowStreamReadAdapter.whenBound(MessageStream stream)
void	DataflowQueue.wheneverBound(MessageStream stream) Send all pieces of data bound in the future to the provided stream when it becomes available.
void	SelectableChannel.wheneverBound(MessageStream stream) Send all pieces of data bound in the future to the provided stream when it becomes available.
void	SyncDataflowStreamReadAdapter.wheneverBound(MessageStream stream)

Uses of MessageStream in groovyx.gpars.dataflow.expression

Subclasses of MessageStream in groovyx.gpars.dataflow.expression

Modifier and Type	Class and Description
(package private) class	DataflowExpression.DataflowExpressionsCollector Listener for availability of data flow expressions we depend on.

Fields in groovyx.gpars.dataflow.expression declared as MessageStream

Modifier and Type	Field and Description
private MessageStream	DataflowExpression.WaitingThread.callback

Methods in groovyx.gpars.dataflow.expression that return MessageStream

Modifier and Type	Method and Description
MessageStream	DataflowExpression.DataflowExpressionsCollector.send(java.lang.Object message)

Methods in groovyx.gpars.dataflow.expression with parameters of type MessageStream

Modifier and Type	Method and Description
void	DataflowExpression.getValAsync(MessageStream callback) Asynchronously retrieves the value of the variable.
void	DataflowExpression.getValAsync(java.lang.Object attachment, MessageStream callback) Used by Dataflow operators.
protected void	DataflowExpression.scheduleCallback(java.lang.Object attachment, MessageStream callback) Sends the result back to the actor, which is waiting asynchronously for the value to be bound.
void	DataflowExpression.whenBound(MessageStream stream) Send the bound data to provided stream when it becomes available
void	DataflowExpression.wheneverBound(MessageStream stream) Send all pieces of data bound in the future to the provided stream when it becomes available.

Constructors in groovyx.gpars.dataflow.expression with parameters of type MessageStream

Constructor and Description
DataflowExpression.WaitingThread(java.lang.Thread thread, DataflowExpression.WaitingThread previous, java.lang.Object attachment, MessageStream callback) Creates a representation of the request to read the value once it is bound

Uses of MessageStream in groovyx.gpars.dataflow.operator

Subclasses of MessageStream in groovyx.gpars.dataflow.operator

Modifier and Type	Class and Description
(package private) class	DataflowOperatorActor An operator's internal actor.
(package private) class	DataflowProcessorActor A base actor class for operators' and selectors' actors
(package private) class	DataflowSelectorActor An selector's internal actor.
(package private) class	ForkingDataflowOperatorActor An operator's internal actor.
(package private) class	ForkingDataflowSelectorActor An selector's internal actor.

Methods in groovyx.gpars.dataflow.operator that return MessageStream

Modifier and Type	Method and Description
MessageStream	DataflowProcessorActor.send(java.lang.Object message) Sends the message, ignoring exceptions caused by the actor not being active anymore

Uses of MessageStream in groovyx.gpars.dataflow.stream

Fields in groovyx.gpars.dataflow.stream with type parameters of type MessageStream

Modifier and Type	Field and Description
protected java.util.Collection<MessageStream>	StreamCore.wheneverBoundListeners A collection of listeners who need to be informed each time the stream is bound to a value

Methods in groovyx.gpars.dataflow.stream with parameters of type MessageStream

Modifier and Type	Method and Description
void	DataflowStreamReadAdapter.getValAsync(MessageStream callback)
void	DataflowStreamReadAdapter.getValAsync(java.lang.Object attachment, MessageStream callback)
void	DataflowStreamReadAdapter.whenBound(MessageStream stream)
void	DataflowStreamReadAdapter.wheneverBound(MessageStream stream)
void	StreamCore.wheneverBound(MessageStream stream)

Constructor parameters in groovyx.gpars.dataflow.stream with type arguments of type MessageStream

Constructor and Description
DataflowStream(java.util.Collection<MessageStream> wheneverBoundListeners, java.util.Collection<DataflowChannelListener<T>> updateListeners)
StreamCore(DataflowVariable<T> first, java.util.Collection<MessageStream> wheneverBoundListeners, java.util.Collection<DataflowChannelListener<T>> updateListeners)
SyncDataflowStream(int parties, java.util.Collection<MessageStream> wheneverBoundListeners, java.util.Collection<DataflowChannelListener<T>> updateListeners) Creates an empty stream with the specified listeners set