Package co.paralleluniverse.strands.channels

Channels - a CSP (Communicating Sequential Processes) construct

See: Description

Interface Summary

Interface	Description
Channel<Message>	A message-passing channel.
DoubleChannel	A channel for primitive double messages.
DoubleReceivePort	A primitive double channel's consumer-side interface.
DoubleSendPort	A primitive double channel's producer-side interface.
FloatChannel	A channel for primitive float messages.
FloatReceivePort	A primitive float channel's consumer-side interface.
FloatSendPort	A primitive float channel's producer-side interface.
IntChannel	A channel for primitive int messages.
IntReceivePort	A primitive int channel's consumer-side interface.
IntSendPort	A primitive int channel's producer-side interface.
LongChannel	A channel for primitive double messages.
LongReceivePort	A primitive long channel's consumer-side interface.
LongSendPort	A primitive long channel's producer-side interface.
Mix<M>	ReceivePort with Mix operations.
Port<Message>	An empty super-interface of SendPort and ReceivePort extend.
PortAutoCloseable
ReceivePort<Message>	A channel's consumer-side functional interface.
Selectable<Message>	A channel port that can be used by a Selector.
SelectReceiveListener<Message>	A listener associated with a receive SelectAction, which is called if an only if the associated action has succeeded.
SelectSendListener<Message>	A listener associated with a send SelectAction, which is called if an only if the associated action has succeeded.
SendPort<Message>	A channel's producer-side functional interface.
StandardChannel<Message>	A common interface for standard channel implementations

Class Summary

Class	Description
Channels	A utility class for creating and manipulating channels.
DelegatingReceivePort<T>
DelegatingSendPort<T>
FlatMappingReceivePort<S,T>
Mix.State
QueueChannel<Message>
QueueDoubleChannel
QueueFloatChannel
QueueIntChannel
QueueLongChannel
QueueObjectChannel<Message>
QueuePrimitiveChannel<Message>	Single consumer!
ReceivePortGroup<M>
SelectAction<Message>	A channel operation that is selected by a Selector.
SelectActionImpl<Message>
Selector<Message>	Attempts to perform at most one channel operation (send or receive) of a given set.
SingleConsumerQueueChannel<Message>
SplitSendPort<Message>	SendPort that will send messages it receives to a target SendPort.
ThreadReceivePort<Message>	This class is a simple convenience wrapper around ReceivePort that can be used by threads (as opposed to fibers).
ThreadSendPort<Message>	This class is a simple convenience wrapper around SendPort that can be used by threads (as opposed to fibers).
TickerChannelConsumer<Message>	A ReceivePort which is a view of a ticker channel.
TickerChannelConsumer.TickerChannelFloatConsumer
TimeoutChannel<Message>
Topic<Message>	A channel that forwards all messages to subscriber channels.
TransferChannel<Message>
TransformingReceivePort<T>	A ReceivePort with additional functional-transform operations, usually wrapping a plain ReceivePort.
TransformingSendPort<T>	A SendPort with additional functional-transform operations, usually wrapping a plain SendPort.
ZippingReceivePort<Message>	Single consumer

Enum Summary

Enum	Description
Channels.OverflowPolicy	Determines how a channel behaves when its internal buffer (if it has one) overflows.
Mix.Mode
Mix.SoloEffect

Exception Summary

Exception	Description
ChannelClosedException
ProducerException	This exception is thrown by a ReceivePort's receive or tryReceive methods if the channel has been closed with an exception.
ReceivePort.EOFException

Package co.paralleluniverse.strands.channels Description

Channels - a CSP (Communicating Sequential Processes) construct