|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface PipelineInjector<Cmd,Evt>
A handle for injecting commands and events into a pipeline. Commands travel down (or to the right) through the stages, events travel in the opposite direction.
PipelineFactory.buildWithSinkFunctions(Ctx, akka.io.PipelineStage, scala.Function1, scala.runtime.BoxedUnit>, scala.Function1, scala.runtime.BoxedUnit>)
,
PipelineFactory.buildWithSink(Ctx, akka.io.PipelineStage, akka.io.PipelineSink)
Method Summary | |
---|---|
void |
injectCommand(Cmd cmd)
Inject the given command into the connected pipeline. |
void |
injectEvent(Evt event)
Inject the given event into the connected pipeline. |
void |
managementCommand(java.lang.Object cmd)
Send a management command to all stages (in an unspecified order). |
Method Detail |
---|
void injectCommand(Cmd cmd)
void injectEvent(Evt event)
void managementCommand(java.lang.Object cmd)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |