|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.io.PipePairFactory
public class PipePairFactory
This class contains static factory methods which produce PipePair
instances; those are needed within the implementation of PipelineStage.apply(Context)
.
Constructor Summary | |
---|---|
PipePairFactory()
|
Method Summary | ||
---|---|---|
static
|
apply(scala.Function1<CmdAbove,scala.collection.Iterable<scala.util.Either<EvtAbove,CmdBelow>>> commandPL,
scala.Function1<EvtBelow,scala.collection.Iterable<scala.util.Either<EvtAbove,CmdBelow>>> eventPL,
scala.PartialFunction<java.lang.Object,scala.collection.Iterable<scala.util.Either<EvtAbove,CmdBelow>>> management)
Scala API: construct a PipePair from the two given functions; useful for not capturing $outer references. |
|
static
|
create(PipelineContext ctx,
AbstractPipePair<CmdAbove,CmdBelow,EvtAbove,EvtBelow> ap)
Java API: construct a PipePair from the given AbstractPipePair . |
|
static
|
create(PipelineContext ctx,
AbstractSymmetricPipePair<Above,Below> ap)
Java API: construct a PipePair from the given AbstractSymmetricPipePair . |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public PipePairFactory()
Method Detail |
---|
public static <CmdAbove,CmdBelow,EvtAbove,EvtBelow> java.lang.Object apply(scala.Function1<CmdAbove,scala.collection.Iterable<scala.util.Either<EvtAbove,CmdBelow>>> commandPL, scala.Function1<EvtBelow,scala.collection.Iterable<scala.util.Either<EvtAbove,CmdBelow>>> eventPL, scala.PartialFunction<java.lang.Object,scala.collection.Iterable<scala.util.Either<EvtAbove,CmdBelow>>> management)
PipePair
from the two given functions; useful for not capturing $outer
references.
public static <CmdAbove,CmdBelow,EvtAbove,EvtBelow> PipePair<CmdAbove,CmdBelow,EvtAbove,EvtBelow> create(PipelineContext ctx, AbstractPipePair<CmdAbove,CmdBelow,EvtAbove,EvtBelow> ap)
PipePair
from the given AbstractPipePair
.
public static <Above,Below> SymmetricPipePair<Above,Below> create(PipelineContext ctx, AbstractSymmetricPipePair<Above,Below> ap)
PipePair
from the given AbstractSymmetricPipePair
.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |