The medium of actor-based channels.
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.
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.
Signals a double usage of an input or output channel endpoint.
Base abstract class for all channel endpoints.
Convenience trait allowing to distinguish the intended direction of a channel or a message type.
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
.
Base abstract class for linear input channel endpoints.
The medium of local channel endpoints.
Local input channel endpoint, usually created via LocalChannel.factory.
Local output channel endpoint, usually created via LocalChannel.factory.
Convenience trait for channels without I/O capabilities.
Base abstract class for output channel endpoints.
Queue-based input endpoint, usually created via QueueChannel.factory.
Queue-based output endpoint, usually created via QueueChannel.factory.
Convenience trait for input channels, and message types whose instances should be received.
Convenience trait for output channels, and message types whose instances should be sent.
The medium of socket-based channel endpoints.
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.
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.
Stream-based input channel endpoint, usually created through the companion object or via StreamManager.factory.
The medium of stream-based channel endpoints.
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.
Base class for stream management and (de)serialization of messages.
Stream-based input channel endpoint, usually created through the companion object or via StreamManager.factory.
Channels that implement message delivery by automatically spawning Akka Typed actors.
Actor-based input channel endpoint.
Actor-based output channel endpoint.
Simple implementation of local channel endpoints,
based on Scala Promise
s/Future
s.
Channel endpoints for local use, based on Java LinkedTransferQueue
s.
Channel endpoints for local use, based on Java LinkedTransferQueue
s.
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 LinkedTransferQueue
s,
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.
Stream-based input channel endpoint.
Stream-based output channel endpoint.
Stream-based input channel endpoint.
Stream-based output channel endpoint.