Class PhasedFusingActorMaterializer$

  • All Implemented Interfaces:
    java.io.Serializable

    public class PhasedFusingActorMaterializer$
    extends java.lang.Object
    implements java.io.Serializable
    INTERNAL API
    See Also:
    Serialized Form
    • 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​(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

        Parameters:
        system - (undocumented)
        settings - (undocumented)
        defaultAttributes - (undocumented)
        dispatchers - (undocumented)
        supervisor - (undocumented)
        haveShutDown - (undocumented)
        flowNames - (undocumented)
        Returns:
        (undocumented)