Channels - a CSP (Communicating Sequential Processes) construct
Interface Summary Interface Description Channel<Message>A message-passing channel. DoubleChannelA channel for primitive
doublechannel's consumer-side interface.
doublechannel's producer-side interface.
FloatChannelA channel for primitive
floatchannel's consumer-side interface.
floatchannel's producer-side interface.
IntChannelA channel for primitive
intchannel's consumer-side interface.
intchannel's producer-side interface.
LongChannelA channel for primitive
longchannel's consumer-side interface.
longchannel's producer-side interface.
ReceivePortwith Mix operations.
Port<Message> PortAutoCloseable ReceivePort<Message>A channel's consumer-side functional interface. Selectable<Message>A channel port that can be used by a
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 ChannelsA 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<Message>Attempts to perform at most one channel operation (send or receive) of a given set. SingleConsumerQueueChannel<Message> SplitSendPort<Message> ThreadReceivePort<Message>This class is a simple convenience wrapper around
ReceivePortthat can be used by threads (as opposed to fibers).
ThreadSendPort<Message>This class is a simple convenience wrapper around
SendPortthat can be used by threads (as opposed to fibers).
TickerChannelConsumer<Message> TickerChannelConsumer.TickerChannelFloatConsumer TimeoutChannel<Message> Topic<Message>A channel that forwards all messages to subscriber channels. TransferChannel<Message> TransformingReceivePort<T> TransformingSendPort<T> ZippingReceivePort<Message>Single consumer
Enum Summary Enum Description Channels.OverflowPolicyDetermines how a channel behaves when its internal buffer (if it has one) overflows. Mix.Mode Mix.SoloEffect
Exception Summary Exception Description ChannelClosedException ProducerException ReceivePort.EOFException