akka.io
Class PipePairFactory

java.lang.Object
  akka.io.PipePairFactory

public class PipePairFactory
extends java.lang.Object

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 <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) Scala API: construct a PipePair from the two given functions; useful for not capturing $outer references.
static <CmdAbove,CmdBelow,EvtAbove,EvtBelow> PipePair<CmdAbove,CmdBelow,EvtAbove,EvtBelow>	create(PipelineContext ctx, AbstractPipePair<CmdAbove,CmdBelow,EvtAbove,EvtBelow> ap) Java API: construct a PipePair from the given AbstractPipePair.
static <Above,Below> SymmetricPipePair<Above,Below>	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

PipePairFactory

public PipePairFactory()

Method Detail

apply

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)

Scala API: construct a PipePair from the two given functions; useful for not capturing $outer references.

create

public static <CmdAbove,CmdBelow,EvtAbove,EvtBelow> PipePair<CmdAbove,CmdBelow,EvtAbove,EvtBelow> create(PipelineContext ctx,
                                                                                                         AbstractPipePair<CmdAbove,CmdBelow,EvtAbove,EvtBelow> ap)

Java API: construct a PipePair from the given AbstractPipePair.

create

public static <Above,Below> SymmetricPipePair<Above,Below> create(PipelineContext ctx,
                                                                  AbstractSymmetricPipePair<Above,Below> ap)

Java API: construct a PipePair from the given AbstractSymmetricPipePair.