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

Field Summary

static PipePairFactory$

MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

PipePairFactory$()

Method Summary

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

Field Detail

MODULE$

public static final PipePairFactory$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

PipePairFactory$

public PipePairFactory$()

Method Detail

apply

public <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 <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 <Above,Below> SymmetricPipePair<Above,Below> create(PipelineContext ctx,
                                                           AbstractSymmetricPipePair<Above,Below> ap)

Java API: construct a PipePair from the given AbstractSymmetricPipePair.