Java API: A pair of pipes, one for commands and one for events.
This base trait of each pipeline’s context provides optimized facilities for generating single commands or events (i.
A convenience type for expressing a AbstractPipePair which has the same types for commands and events.
This pipeline stage implements a configurable buffer for transforming the per-write ACK/NACK-based backpressure model of a TCP connection actor into an edge-triggered back-pressure model: the upper stages will receive notification when the buffer runs full (BackpressureBuffer.HighWatermarkReached) and when it subsequently empties (BackpressureBuffer.LowWatermarkReached).
Pipeline stage for delimiter byte based framing and de-framing.
This trait expresses that the pipeline’s context needs to live within an actor and provide its ActorContext.
This trait expresses that the pipeline’s context needs to provide a logging facility.
Pipeline stage for length-field encoded framing.
Scala API: A pair of pipes, one for commands and one for events, plus a management port.
This base trait of each pipeline’s context provides optimized facilities for generating single commands or events (i.
A handle for injecting commands and events into a pipeline.
A sink which can be attached by PipelineFactory#buildWithSink to a pipeline when it is being built.
A pipeline stage which can be combined with other stages to build a protocol stack.
This pipeline stage implements SSL / TLS support, using an externally configured javax.net.ssl.SSLEngine.
Simple convenience pipeline stage for turning Strings into ByteStrings and vice versa.
A convenience type for expressing a PipePair which has the same types for commands and events.
A PipelineStage which is symmetric in command and event types, i.
This actor wraps a pipeline and forwards commands and events between that one and a Tcp connection actor.
Adapts a ByteString oriented pipeline stage to a stage that communicates via Tcp Commands and Events.
This pipeline stage does not alter the events or commands
Entry point to Akka’s IO layer.
This class contains static factory methods which produce PipePair instances; those are needed within the implementation of PipelineStage#apply.
This class contains static factory methods which turn a pipeline context and a PipelineStage into readily usable pipelines.
TCP Extension for Akka’s IO layer.
Java API for accessing socket options.
UDP Extension for Akka’s IO layer.
UDP Extension for Akka’s IO layer.
Java API: factory methods for the message types used when communicating with the UdpConnected service.
Java API: factory methods for the message types used when communicating with the Udp service.