Package

lchannels

Permalink

package lchannels

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. lchannels
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. case class Actor() extends Product with Serializable

    Permalink

    The medium of actor-based channels.

  2. class ActorIn[T] extends lchannels.medium.In[Actor, T] with Serializable

    Permalink

    Actor-based input channel endpoint, usually created through the companion object or via ActorChannel.factory.

    Actor-based input channel endpoint, usually created through the companion object or via ActorChannel.factory.

    Attributes
    protected
    Annotations
    @SerialVersionUID()
  3. class ActorOut[-T] extends lchannels.medium.Out[Actor, T] with Serializable

    Permalink

    Actor-based output channel endpoint, usually created through the companion object or via ActorChannel.factory.

    Actor-based output channel endpoint, usually created through the companion object or via ActorChannel.factory.

    Attributes
    protected
    Annotations
    @SerialVersionUID()
  4. class AlreadyUsed extends IllegalStateException

    Permalink

    Signals a double usage of an input or output channel endpoint.

  5. abstract class Channel[D <: Direction] extends AnyRef

    Permalink

    Base abstract class for all channel endpoints.

  6. sealed trait Direction extends AnyRef

    Permalink

    Convenience trait allowing to distinguish the intended direction of a channel or a message type.

  7. case class End() extends Channel[None] with Product with Serializable

    Permalink

    Linear channel endpoint without input/output capabilities.

    Linear channel endpoint without input/output capabilities.

    For most practical purposes, instances of this object can be often replaced with instances of Unit.

  8. abstract class In[+T] extends Channel[Receive]

    Permalink

    Base abstract class for linear input channel endpoints.

  9. case class Local() extends Product with Serializable

    Permalink

    The medium of local channel endpoints.

  10. class LocalIn[+T] extends lchannels.medium.In[Local, T]

    Permalink

    Local input channel endpoint, usually created via LocalChannel.factory.

  11. class LocalOut[-T] extends lchannels.medium.Out[Local, T]

    Permalink

    Local output channel endpoint, usually created via LocalChannel.factory.

  12. trait None extends Direction

    Permalink

    Convenience trait for channels without I/O capabilities.

  13. abstract class Out[-T] extends Channel[Send]

    Permalink

    Base abstract class for output channel endpoints.

  14. class QueueIn[+T] extends lchannels.medium.In[Local, T]

    Permalink

    Queue-based input endpoint, usually created via QueueChannel.factory.

  15. class QueueOut[-T] extends lchannels.medium.Out[Local, T]

    Permalink

    Queue-based output endpoint, usually created via QueueChannel.factory.

  16. trait Receive extends Direction

    Permalink

    Convenience trait for input channels, and message types whose instances should be received.

  17. trait Send extends Direction

    Permalink

    Convenience trait for output channels, and message types whose instances should be sent.

  18. case class Socket() extends Product with Serializable

    Permalink

    The medium of socket-based channel endpoints.

  19. class SocketIn[T] extends lchannels.medium.In[Socket, T]

    Permalink

    Stream-based input channel endpoint, usually created through the companion object or via StreamManager.factory.

    Stream-based input channel endpoint, usually created through the companion object or via StreamManager.factory.

    Attributes
    protected
  20. abstract class SocketManager extends AnyRef

    Permalink

    Base class for socket management and (de)serialization of messages.

    Base class for socket management and (de)serialization of messages.

    This class assumes to have exclusive control over the given socket.

  21. class SocketOut[-T] extends lchannels.medium.Out[Socket, T]

    Permalink

    Stream-based input channel endpoint, usually created through the companion object or via StreamManager.factory.

  22. case class Stream() extends Product with Serializable

    Permalink

    The medium of stream-based channel endpoints.

  23. class StreamIn[T] extends lchannels.medium.In[Stream, T]

    Permalink

    Stream-based input channel endpoint, usually created through the companion object or via StreamManager.factory.

    Stream-based input channel endpoint, usually created through the companion object or via StreamManager.factory.

    Attributes
    protected
  24. abstract class StreamManager extends AnyRef

    Permalink

    Base class for stream management and (de)serialization of messages.

  25. class StreamOut[-T] extends lchannels.medium.Out[Stream, T]

    Permalink

    Stream-based input channel endpoint, usually created through the companion object or via StreamManager.factory.

Value Members

  1. object ActorChannel

    Permalink

    Channels that implement message delivery by automatically spawning Akka Typed actors.

  2. object ActorIn extends Serializable

    Permalink

    Actor-based input channel endpoint.

  3. object ActorOut extends Serializable

    Permalink

    Actor-based output channel endpoint.

  4. object Defaults

    Permalink
    Attributes
    protected
  5. object LocalChannel

    Permalink

    Simple implementation of local channel endpoints, based on Scala Promises/Futures.

  6. object QueueChannel

    Permalink

    Channel endpoints for local use, based on Java LinkedTransferQueues.

    Channel endpoints for local use, based on Java LinkedTransferQueues.

    Queue-based channels are (almost) a drop-in replacement for LocalChannels. They are optimized for bypassing Out.promise and In.future whenever possible, e.g. when a program mostly calls Out.send and In.receive; as a consequence, if QueueOut.promise or QueueIn.future are used, the performance will be impacted.

    NOTE: due to limitations of Java LinkedTransferQueues, invoking QueueIn.receive on a QueueIn[Null] instance with a finite wait time will cause a spurious timeout error. If you really need channel endpoints that carry Null values, you should use LocalChannels.

  7. object SocketIn

    Permalink

    Stream-based input channel endpoint.

  8. object SocketOut

    Permalink

    Stream-based output channel endpoint.

  9. object StreamIn

    Permalink

    Stream-based input channel endpoint.

  10. object StreamOut

    Permalink

    Stream-based output channel endpoint.

  11. package medium

    Permalink
  12. package protocol

    Permalink
  13. package util

    Permalink

Inherited from AnyRef

Inherited from Any

Ungrouped