Package akka.stream.impl

Class PhasedFusingActorMaterializer$

java.lang.Object

akka.stream.impl.PhasedFusingActorMaterializer$

All Implemented Interfaces:

java.io.Serializable

public class PhasedFusingActorMaterializer$
extends java.lang.Object
implements java.io.Serializable

INTERNAL API

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static PhasedFusingActorMaterializer$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
PhasedFusingActorMaterializer$()

Method Summary

Modifier and Type	Method	Description
PhasedFusingActorMaterializer	apply(ActorContext context, java.lang.String namePrefix, ActorMaterializerSettings settings, Attributes attributes)
PhasedFusingActorMaterializer	apply(ActorSystem system, ActorMaterializerSettings settings, Attributes defaultAttributes, Dispatchers dispatchers, ActorRef supervisor, java.util.concurrent.atomic.AtomicBoolean haveShutDown, SeqActorName flowNames)	INTERNAL API
boolean	Debug()
Phase<java.lang.Object>	DefaultPhase()
scala.collection.immutable.Map<IslandTag,Phase<java.lang.Object>>	DefaultPhases()
scala.Option<scala.Tuple7<ActorSystem,ActorMaterializerSettings,Attributes,Dispatchers,ActorRef,java.util.concurrent.atomic.AtomicBoolean,SeqActorName>>	unapply(PhasedFusingActorMaterializer x$0)

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final PhasedFusingActorMaterializer$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

PhasedFusingActorMaterializer$

public PhasedFusingActorMaterializer$()

Method Detail

Debug

public boolean Debug()

DefaultPhase

public Phase<java.lang.Object> DefaultPhase()

DefaultPhases

public scala.collection.immutable.Map<IslandTag,Phase<java.lang.Object>> DefaultPhases()

apply

public PhasedFusingActorMaterializer apply(ActorContext context,
                                           java.lang.String namePrefix,
                                           ActorMaterializerSettings settings,
                                           Attributes attributes)

apply

public PhasedFusingActorMaterializer apply(ActorSystem system,
                                           ActorMaterializerSettings settings,
                                           Attributes defaultAttributes,
                                           Dispatchers dispatchers,
                                           ActorRef supervisor,
                                           java.util.concurrent.atomic.AtomicBoolean haveShutDown,
                                           SeqActorName flowNames)

INTERNAL API

defaultAttributes for the materializer, based on the ActorMaterializerSettings and are always seen as least specific, so any attribute specified in the graph "wins" over these. In addition to that this also guarantees that the attributes InputBuffer, SupervisionStrategy, and Dispatcher is _always_ present in the attributes and can be accessed through Attributes.mandatoryAttribute

When these attributes are needed later in the materialization process it is important that they are gotten through the attributes and not through the ActorMaterializerSettings

unapply

public scala.Option<scala.Tuple7<ActorSystem,ActorMaterializerSettings,Attributes,Dispatchers,ActorRef,java.util.concurrent.atomic.AtomicBoolean,SeqActorName>> unapply(PhasedFusingActorMaterializer x$0)