Hierarchy For Package co.paralleluniverse.strands.channels

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • co.paralleluniverse.strands.channels.Channels
  • co.paralleluniverse.strands.channels.DelegatingReceivePort<T> (implements co.paralleluniverse.common.util.DelegatingEquals, co.paralleluniverse.strands.channels.ReceivePort<Message>)
    • co.paralleluniverse.strands.channels.TransformingReceivePort<T>
  • co.paralleluniverse.strands.channels.DelegatingSendPort<T> (implements co.paralleluniverse.common.util.DelegatingEquals, co.paralleluniverse.strands.channels.SendPort<Message>)
    • co.paralleluniverse.strands.channels.TransformingSendPort<T>
  • co.paralleluniverse.strands.channels.FlatMappingReceivePort<S,T> (implements co.paralleluniverse.strands.channels.ReceivePort<Message>)
  • co.paralleluniverse.strands.channels.Mix.State
  • co.paralleluniverse.strands.channels.QueueChannel<Message> (implements co.paralleluniverse.strands.channels.Selectable<Message>, java.io.Serializable, co.paralleluniverse.strands.channels.StandardChannel<Message>, co.paralleluniverse.strands.Synchronization)
    • co.paralleluniverse.strands.channels.QueueObjectChannel<Message>
    • co.paralleluniverse.strands.channels.QueuePrimitiveChannel<Message> (implements co.paralleluniverse.strands.Stranded)
      • co.paralleluniverse.strands.channels.QueueDoubleChannel (implements co.paralleluniverse.strands.channels.DoubleChannel)
      • co.paralleluniverse.strands.channels.QueueFloatChannel (implements co.paralleluniverse.strands.channels.FloatChannel)
      • co.paralleluniverse.strands.channels.QueueIntChannel (implements co.paralleluniverse.strands.channels.IntChannel)
      • co.paralleluniverse.strands.channels.QueueLongChannel (implements co.paralleluniverse.strands.channels.LongChannel)
    • co.paralleluniverse.strands.channels.SingleConsumerQueueChannel<Message> (implements co.paralleluniverse.strands.Stranded)
  • co.paralleluniverse.strands.channels.ReceivePortGroup<M> (implements co.paralleluniverse.strands.channels.Mix<M>)
  • co.paralleluniverse.strands.channels.SelectAction<Message>
    • co.paralleluniverse.strands.channels.SelectActionImpl<Message>
  • co.paralleluniverse.strands.channels.Selector<Message> (implements co.paralleluniverse.strands.Synchronization)
  • co.paralleluniverse.strands.channels.SplitSendPort<Message> (implements co.paralleluniverse.strands.channels.SendPort<Message>)
  • co.paralleluniverse.strands.channels.ThreadReceivePort<Message>
  • co.paralleluniverse.strands.channels.ThreadSendPort<Message>
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • co.paralleluniverse.strands.channels.ReceivePort.EOFException
      • java.lang.RuntimeException
        • co.paralleluniverse.strands.channels.ChannelClosedException
        • co.paralleluniverse.strands.channels.ProducerException
  • co.paralleluniverse.strands.channels.TickerChannelConsumer<Message> (implements co.paralleluniverse.strands.channels.ReceivePort<Message>, co.paralleluniverse.strands.channels.Selectable<Message>)
    • co.paralleluniverse.strands.channels.TickerChannelConsumer.TickerChannelFloatConsumer (implements co.paralleluniverse.strands.channels.FloatReceivePort)
  • co.paralleluniverse.strands.channels.Topic<Message>
  • co.paralleluniverse.strands.channels.TransferChannel<Message> (implements co.paralleluniverse.strands.channels.Selectable<Message>, co.paralleluniverse.strands.channels.StandardChannel<Message>, co.paralleluniverse.strands.Synchronization)
    • co.paralleluniverse.strands.channels.TimeoutChannel<Message>
  • co.paralleluniverse.strands.channels.ZippingReceivePort<Message> (implements co.paralleluniverse.strands.channels.ReceivePort<Message>)

Interface Hierarchy

• java.lang.AutoCloseable
  • co.paralleluniverse.strands.channels.PortAutoCloseable
    • co.paralleluniverse.strands.channels.ReceivePort<Message> (also extends co.paralleluniverse.strands.channels.Port<Message>)
      • co.paralleluniverse.strands.channels.Channel<Message> (also extends co.paralleluniverse.strands.channels.SendPort<Message>)
        • co.paralleluniverse.strands.channels.StandardChannel<Message>
      • co.paralleluniverse.strands.channels.DoubleReceivePort
        • co.paralleluniverse.strands.channels.DoubleChannel (also extends co.paralleluniverse.strands.channels.DoubleSendPort)
      • co.paralleluniverse.strands.channels.FloatReceivePort
        • co.paralleluniverse.strands.channels.FloatChannel (also extends co.paralleluniverse.strands.channels.FloatSendPort)
      • co.paralleluniverse.strands.channels.IntReceivePort
        • co.paralleluniverse.strands.channels.IntChannel (also extends co.paralleluniverse.strands.channels.IntSendPort)
      • co.paralleluniverse.strands.channels.LongReceivePort
        • co.paralleluniverse.strands.channels.LongChannel (also extends co.paralleluniverse.strands.channels.LongSendPort)
      • co.paralleluniverse.strands.channels.Mix<M>
    • co.paralleluniverse.strands.channels.SendPort<Message> (also extends co.paralleluniverse.strands.channels.Port<Message>)
      • co.paralleluniverse.strands.channels.Channel<Message> (also extends co.paralleluniverse.strands.channels.ReceivePort<Message>)
        • co.paralleluniverse.strands.channels.StandardChannel<Message>
      • co.paralleluniverse.strands.channels.DoubleSendPort
        • co.paralleluniverse.strands.channels.DoubleChannel (also extends co.paralleluniverse.strands.channels.DoubleReceivePort)
      • co.paralleluniverse.strands.channels.FloatSendPort
        • co.paralleluniverse.strands.channels.FloatChannel (also extends co.paralleluniverse.strands.channels.FloatReceivePort)
      • co.paralleluniverse.strands.channels.IntSendPort
        • co.paralleluniverse.strands.channels.IntChannel (also extends co.paralleluniverse.strands.channels.IntReceivePort)
      • co.paralleluniverse.strands.channels.LongSendPort
        • co.paralleluniverse.strands.channels.LongChannel (also extends co.paralleluniverse.strands.channels.LongReceivePort)
• co.paralleluniverse.strands.channels.Port<Message>
  • co.paralleluniverse.strands.channels.ReceivePort<Message> (also extends co.paralleluniverse.strands.channels.PortAutoCloseable)
    • co.paralleluniverse.strands.channels.Channel<Message> (also extends co.paralleluniverse.strands.channels.SendPort<Message>)
      • co.paralleluniverse.strands.channels.StandardChannel<Message>
    • co.paralleluniverse.strands.channels.DoubleReceivePort
      • co.paralleluniverse.strands.channels.DoubleChannel (also extends co.paralleluniverse.strands.channels.DoubleSendPort)
    • co.paralleluniverse.strands.channels.FloatReceivePort
      • co.paralleluniverse.strands.channels.FloatChannel (also extends co.paralleluniverse.strands.channels.FloatSendPort)
    • co.paralleluniverse.strands.channels.IntReceivePort
      • co.paralleluniverse.strands.channels.IntChannel (also extends co.paralleluniverse.strands.channels.IntSendPort)
    • co.paralleluniverse.strands.channels.LongReceivePort
      • co.paralleluniverse.strands.channels.LongChannel (also extends co.paralleluniverse.strands.channels.LongSendPort)
    • co.paralleluniverse.strands.channels.Mix<M>
  • co.paralleluniverse.strands.channels.Selectable<Message>
  • co.paralleluniverse.strands.channels.SendPort<Message> (also extends co.paralleluniverse.strands.channels.PortAutoCloseable)
    • co.paralleluniverse.strands.channels.Channel<Message> (also extends co.paralleluniverse.strands.channels.ReceivePort<Message>)
      • co.paralleluniverse.strands.channels.StandardChannel<Message>
    • co.paralleluniverse.strands.channels.DoubleSendPort
      • co.paralleluniverse.strands.channels.DoubleChannel (also extends co.paralleluniverse.strands.channels.DoubleReceivePort)
    • co.paralleluniverse.strands.channels.FloatSendPort
      • co.paralleluniverse.strands.channels.FloatChannel (also extends co.paralleluniverse.strands.channels.FloatReceivePort)
    • co.paralleluniverse.strands.channels.IntSendPort
      • co.paralleluniverse.strands.channels.IntChannel (also extends co.paralleluniverse.strands.channels.IntReceivePort)
    • co.paralleluniverse.strands.channels.LongSendPort
      • co.paralleluniverse.strands.channels.LongChannel (also extends co.paralleluniverse.strands.channels.LongReceivePort)
• co.paralleluniverse.strands.channels.SelectListener<Message>
  • co.paralleluniverse.strands.channels.SelectReceiveListener<Message>
  • co.paralleluniverse.strands.channels.SelectSendListener<Message>

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • co.paralleluniverse.strands.channels.Mix.SoloEffect
    • co.paralleluniverse.strands.channels.Mix.Mode
    • co.paralleluniverse.strands.channels.Channels.OverflowPolicy