akka

io

package io

Visibility
  1. Public
  2. All

Type Members

  1. abstract class AbstractPipePair[CmdAbove, CmdBelow, EvtAbove, EvtBelow] extends AnyRef

    Java API: A pair of pipes, one for commands and one for events.

  2. abstract class AbstractPipelineContext extends PipelineContext

    This base trait of each pipeline’s context provides optimized facilities for generating single commands or events (i.

  3. abstract class AbstractSymmetricPipePair[Above, Below] extends AbstractPipePair[Above, Below, Above, Below]

    A convenience type for expressing a AbstractPipePair which has the same types for commands and events.

  4. class BackpressureBuffer extends PipelineStage[HasLogging, Command, Command, Event, Event]

    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).

  5. trait BufferPool extends AnyRef

  6. class DelimiterFraming extends SymmetricPipelineStage[PipelineContext, ByteString, ByteString]

    Pipeline stage for delimiter byte based framing and de-framing.

  7. trait HasActorContext extends PipelineContext

    This trait expresses that the pipeline’s context needs to live within an actor and provide its ActorContext.

  8. trait HasLogging extends PipelineContext

    This trait expresses that the pipeline’s context needs to provide a logging facility.

  9. class LengthFieldFrame extends SymmetricPipelineStage[PipelineContext, ByteString, ByteString]

    Pipeline stage for length-field encoded framing.

  10. trait PipePair[CmdAbove, CmdBelow, EvtAbove, EvtBelow] extends AnyRef

    Scala API: A pair of pipes, one for commands and one for events, plus a management port.

  11. trait PipelineContext extends AnyRef

    This base trait of each pipeline’s context provides optimized facilities for generating single commands or events (i.

  12. trait PipelineInjector[Cmd, Evt] extends AnyRef

    A handle for injecting commands and events into a pipeline.

  13. case class PipelinePorts[CmdAbove, CmdBelow, EvtAbove, EvtBelow](commands: (CmdAbove) ⇒ (Iterable[EvtAbove], Iterable[CmdBelow]), events: (EvtBelow) ⇒ (Iterable[EvtAbove], Iterable[CmdBelow]), management: PartialFunction[AnyRef, (Iterable[EvtAbove], Iterable[CmdBelow])]) extends Product with Serializable

  14. abstract class PipelineSink[Cmd, Evt] extends AnyRef

    A sink which can be attached by PipelineFactory#buildWithSink to a pipeline when it is being built.

  15. abstract class PipelineStage[Context <: PipelineContext, CmdAbove, CmdBelow, EvtAbove, EvtBelow] extends AnyRef

    A pipeline stage which can be combined with other stages to build a protocol stack.

  16. abstract class SelectionHandlerSettings extends AnyRef

  17. class SslTlsSupport extends PipelineStage[HasLogging, Command, Command, Event, Event]

    This pipeline stage implements SSL / TLS support, using an externally configured javax.net.ssl.SSLEngine.

  18. class StringByteStringAdapter extends PipelineStage[PipelineContext, String, ByteString, String, ByteString]

    Simple convenience pipeline stage for turning Strings into ByteStrings and vice versa.

  19. trait SymmetricPipePair[Above, Below] extends PipePair[Above, Below, Above, Below]

    A convenience type for expressing a PipePair which has the same types for commands and events.

  20. abstract class SymmetricPipelineStage[Context <: PipelineContext, Above, Below] extends PipelineStage[Context, Above, Below, Above, Below]

    A PipelineStage which is symmetric in command and event types, i.

  21. class TcpExt extends Extension

  22. class TcpPipelineHandler[Ctx <: PipelineContext, Cmd, Evt] extends Actor with RequiresMessageQueue[UnboundedMessageQueueSemantics]

    This actor wraps a pipeline and forwards commands and events between that one and a Tcp connection actor.

  23. class TcpReadWriteAdapter extends PipelineStage[PipelineContext, ByteString, Command, ByteString, Event]

    Adapts a ByteString oriented pipeline stage to a stage that communicates via Tcp Commands and Events.

  24. class TickGenerator[Cmd <: AnyRef, Evt <: AnyRef] extends PipelineStage[HasActorContext, Cmd, Cmd, Evt, Evt]

    This pipeline stage does not alter the events or commands

  25. class UdpConnectedExt extends Extension

  26. class UdpExt extends Extension

Value Members

  1. object BackpressureBuffer

  2. object IO

    Entry point to Akka’s IO layer.

  3. object Inet

  4. object PipePairFactory

    This class contains static factory methods which produce PipePair instances; those are needed within the implementation of PipelineStage#apply.

  5. object PipelineFactory

    This class contains static factory methods which turn a pipeline context and a PipelineStage into readily usable pipelines.

  6. object PipelineStage

  7. object SslTlsSupport

  8. object Tcp extends ExtensionId[TcpExt] with ExtensionIdProvider

    TCP Extension for Akka’s IO layer.

  9. object TcpMessage

  10. object TcpPipelineHandler

  11. object TcpSO extends SoJavaFactories

    Java API for accessing socket options.

  12. object TickGenerator

  13. object Udp extends ExtensionId[UdpExt] with ExtensionIdProvider

    UDP Extension for Akka’s IO layer.

  14. object UdpConnected extends ExtensionId[UdpConnectedExt] with ExtensionIdProvider

    UDP Extension for Akka’s IO layer.

  15. object UdpConnectedMessage

    Java API: factory methods for the message types used when communicating with the UdpConnected service.

  16. object UdpMessage

    Java API: factory methods for the message types used when communicating with the Udp service.

  17. object UdpSO extends SoJavaFactories

Ungrouped