akka.io
Class TcpPipelineHandler.Init<Ctx extends PipelineContext,Cmd,Evt>

java.lang.Object
  akka.io.TcpPipelineHandler.Init<Ctx,Cmd,Evt>

Enclosing class:

TcpPipelineHandler<Ctx extends PipelineContext,Cmd,Evt>

public abstract static class TcpPipelineHandler.Init<Ctx extends PipelineContext,Cmd,Evt>
extends java.lang.Object

This class wraps up a pipeline with its external (i.e. “top”) command and event types and providing unique wrappers for sending commands and receiving events (nested and non-static classes which are specific to each instance of TcpPipelineHandler.Init). All events emitted by the pipeline will be sent to the registered handler wrapped in an Event.

Nested Class Summary

class	TcpPipelineHandler.Init.Command Wrapper class for commands to be sent to the TcpPipelineHandler actor.
class	TcpPipelineHandler.Init.Event Wrapper class for events emitted by the TcpPipelineHandler actor.

Constructor Summary

TcpPipelineHandler.Init(PipelineStage<? extends PipelineContext,Cmd,Tcp.Command,Evt,Tcp.Event> stages)

Method Summary

TcpPipelineHandler.Init.Command	command(Cmd cmd) Java API: construct a command to be sent to the TcpPipelineHandler actor.
Evt	event(java.lang.Object evt) Java API: extract a wrapped event received from the TcpPipelineHandler actor.
abstract Ctx	makeContext(ActorContext actorContext) This method must be implemented to return the PipelineContext necessary for the operation of the given PipelineStage.
java.lang.Object	stages()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TcpPipelineHandler.Init

public TcpPipelineHandler.Init(PipelineStage<? extends PipelineContext,Cmd,Tcp.Command,Evt,Tcp.Event> stages)

Method Detail

stages

public java.lang.Object stages()

makeContext

public abstract Ctx makeContext(ActorContext actorContext)

This method must be implemented to return the PipelineContext necessary for the operation of the given PipelineStage.

command

public TcpPipelineHandler.Init.Command command(Cmd cmd)

Java API: construct a command to be sent to the TcpPipelineHandler actor.

event

public Evt event(java.lang.Object evt)

Java API: extract a wrapped event received from the TcpPipelineHandler actor.

Throws:

MatchError - if the given object is not an Event matching this specific Init instance.