java.lang.Object
- akka.stream.Materializer
- - akka.stream.ActorMaterializer
  - - akka.stream.impl.ExtendedActorMaterializer
    - - akka.stream.impl.PhasedFusingActorMaterializer

All Implemented Interfaces:

MaterializerLoggingProvider, java.io.Serializable, scala.Equals, scala.Product, scala.Serializable
```
public class PhasedFusingActorMaterializer
extends ExtendedActorMaterializer
implements scala.Product, scala.Serializable
```
See Also:

Serialized Form

Constructor Summary

Constructors
Constructor	Description
`PhasedFusingActorMaterializer(ActorSystem system, ActorMaterializerSettings settings, Dispatchers dispatchers, ActorRef supervisor, java.util.concurrent.atomic.AtomicBoolean haveShutDown, SeqActorName flowNames)`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static ActorMaterializer`	`apply(ActorRefFactory context)`
`static PhasedFusingActorMaterializer`	`apply(ActorSystem system, ActorMaterializerSettings settings, Dispatchers dispatchers, ActorRef supervisor, java.util.concurrent.atomic.AtomicBoolean haveShutDown, SeqActorName flowNames)`	INTERNAL API
`boolean`	`canEqual(java.lang.Object x$1)`
`PhasedFusingActorMaterializer`	`copy(ActorSystem system, ActorMaterializerSettings settings, Dispatchers dispatchers, ActorRef supervisor, java.util.concurrent.atomic.AtomicBoolean haveShutDown, SeqActorName flowNames)`
`ActorSystem`	`copy$default$1()`
`ActorMaterializerSettings`	`copy$default$2()`
`Dispatchers`	`copy$default$3()`
`ActorRef`	`copy$default$4()`
`java.util.concurrent.atomic.AtomicBoolean`	`copy$default$5()`
`SeqActorName`	`copy$default$6()`
`static boolean`	`Debug()`
`Attributes`	`defaultAttributes()`	Default attributes for the materializer, based on the `ActorMaterializerSettings` and are always seen as least specific, so any attribute specified in the graph "wins" over these.
`static Phase<java.lang.Object>`	`DefaultPhase()`
`static scala.collection.immutable.Map<IslandTag,Phase<java.lang.Object>>`	`DefaultPhases()`
`Dispatchers`	`dispatchers()`
`boolean`	`equals(java.lang.Object x$1)`
`scala.concurrent.ExecutionContextExecutor`	`executionContext()`	Running a flow graph will require execution resources, as will computations within Sources, Sinks, etc.
`SeqActorName`	`flowNames()`
`int`	`hashCode()`
`java.util.concurrent.atomic.AtomicBoolean`	`haveShutDown()`
`boolean`	`isShutdown()`	Indicates if the materializer has been shut down.
`LoggingAdapter`	`logger()`	INTERNAL API
`LoggingAdapter`	`makeLogger(java.lang.Class<?> logSource)`
`<Mat> Mat`	`materialize(Graph<ClosedShape,Mat> _runnableGraph)`	INTERNAL API
`<Mat> Mat`	`materialize(Graph<ClosedShape,Mat> _runnableGraph, Attributes defaultAttributes)`	INTERNAL API
`<Mat> Mat`	`materialize(Graph<ClosedShape,Mat> graph, Attributes defaultAttributes, Phase<java.lang.Object> defaultPhase, scala.collection.immutable.Map<IslandTag,Phase<java.lang.Object>> phases)`	INTERNAL API
`int`	`productArity()`
`java.lang.Object`	`productElement(int x$1)`
`scala.collection.Iterator<java.lang.Object>`	`productIterator()`
`java.lang.String`	`productPrefix()`
`Cancellable`	`scheduleOnce(scala.concurrent.duration.FiniteDuration delay, java.lang.Runnable task)`	Interface for operators that need timer services for their functionality.
`Cancellable`	`schedulePeriodically(scala.concurrent.duration.FiniteDuration initialDelay, scala.concurrent.duration.FiniteDuration interval, java.lang.Runnable task)`	Interface for operators that need timer services for their functionality.
`ActorMaterializerSettings`	`settings()`
`void`	`shutdown()`	Shuts down this materializer and all the operators that have been materialized through this materializer.
`ActorRef`	`supervisor()`	INTERNAL API
`ActorSystem`	`system()`	INTERNAL API
`java.lang.String`	`toString()`
`static scala.Option<scala.Tuple6<ActorSystem,ActorMaterializerSettings,Dispatchers,ActorRef,java.util.concurrent.atomic.AtomicBoolean,SeqActorName>>`	`unapply(PhasedFusingActorMaterializer x$0)`
`PhasedFusingActorMaterializer`	`withNamePrefix(java.lang.String name)`

Methods inherited from class akka.stream.impl.ExtendedActorMaterializer
actorOf, actorOf

Methods inherited from class akka.stream.ActorMaterializer
apply, apply, apply, apply$default$1, apply$default$2, create, create, create, systemMaterializer

Methods inherited from class akka.stream.Materializer
matFromSystem

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - PhasedFusingActorMaterializer
```
public PhasedFusingActorMaterializer(ActorSystem system,
                                     ActorMaterializerSettings settings,
                                     Dispatchers dispatchers,
                                     ActorRef supervisor,
                                     java.util.concurrent.atomic.AtomicBoolean haveShutDown,
                                     SeqActorName flowNames)
```
- Method Detail
  - Debug
```
public static boolean Debug()
```
  - DefaultPhase
```
public static Phase<java.lang.Object> DefaultPhase()
```
  - DefaultPhases
```
public static scala.collection.immutable.Map<IslandTag,Phase<java.lang.Object>> DefaultPhases()
```
  - apply
```
public static ActorMaterializer apply(ActorRefFactory context)
```
  - apply
```
public static PhasedFusingActorMaterializer apply(ActorSystem system,
                                                  ActorMaterializerSettings settings,
                                                  Dispatchers dispatchers,
                                                  ActorRef supervisor,
                                                  java.util.concurrent.atomic.AtomicBoolean haveShutDown,
                                                  SeqActorName flowNames)
```
    INTERNAL API
    
    Parameters:
    
    system - (undocumented)
    
    settings - (undocumented)
    
    dispatchers - (undocumented)
    
    supervisor - (undocumented)
    
    haveShutDown - (undocumented)
    
    flowNames - (undocumented)
    
    Returns:
    
    (undocumented)
  - unapply
```
public static scala.Option<scala.Tuple6<ActorSystem,ActorMaterializerSettings,Dispatchers,ActorRef,java.util.concurrent.atomic.AtomicBoolean,SeqActorName>> unapply(PhasedFusingActorMaterializer x$0)
```
  - system
```
public ActorSystem system()
```
    Description copied from class: ActorMaterializer
    
    INTERNAL API
    
    Specified by:
    
    system in class ActorMaterializer
    
    Returns:
    
    (undocumented)
  - settings
```
public ActorMaterializerSettings settings()
```
    Specified by:
    
    settings in class ActorMaterializer
  - dispatchers
```
public Dispatchers dispatchers()
```
  - supervisor
```
public ActorRef supervisor()
```
    Description copied from class: ExtendedActorMaterializer
    
    INTERNAL API
    
    Specified by:
    
    supervisor in class ExtendedActorMaterializer
    
    Returns:
    
    (undocumented)
  - haveShutDown
```
public java.util.concurrent.atomic.AtomicBoolean haveShutDown()
```
  - flowNames
```
public SeqActorName flowNames()
```
  - logger
```
public LoggingAdapter logger()
```
    Description copied from class: ExtendedActorMaterializer
    
    INTERNAL API
    
    Specified by:
    
    logger in class ExtendedActorMaterializer
    
    Returns:
    
    (undocumented)
  - shutdown
```
public void shutdown()
```
    Description copied from class: ActorMaterializer
    
    Shuts down this materializer and all the operators that have been materialized through this materializer. After having shut down, this materializer cannot be used again. Any attempt to materialize operators after having shut down will result in an IllegalStateException being thrown at materialization time.
    
    Specified by:
    
    shutdown in class ActorMaterializer
  - isShutdown
```
public boolean isShutdown()
```
    Description copied from class: ActorMaterializer
    
    Indicates if the materializer has been shut down.
    
    Specified by:
    
    isShutdown in class ActorMaterializer
    
    Returns:
    
    (undocumented)
  - withNamePrefix
```
public PhasedFusingActorMaterializer withNamePrefix(java.lang.String name)
```
    Specified by:
    
    withNamePrefix in class ExtendedActorMaterializer
  - defaultAttributes
```
public Attributes defaultAttributes()
```
    Default attributes 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 the they are gotten through the attributes and not through the ActorMaterializerSettings
    
    Returns:
    
    (undocumented)
  - executionContext
```
public scala.concurrent.ExecutionContextExecutor executionContext()
```
    Description copied from class: Materializer
    
    Running a flow graph will require execution resources, as will computations within Sources, Sinks, etc. This ExecutionContextExecutor can be used by parts of the flow to submit processing jobs for execution, run Future callbacks, etc.
    Note that this is not necessarily the same execution context the stream operator itself is running on.
    
    Specified by:
    
    executionContext in class Materializer
    
    Returns:
    
    (undocumented)
  - schedulePeriodically
```
public Cancellable schedulePeriodically(scala.concurrent.duration.FiniteDuration initialDelay,
                                        scala.concurrent.duration.FiniteDuration interval,
                                        java.lang.Runnable task)
```
    Description copied from class: Materializer
    
    Interface for operators that need timer services for their functionality. Schedules a repeated task with the given interval between invocations.
    
    Specified by:
    
    schedulePeriodically in class Materializer
    
    Parameters:
    
    initialDelay - (undocumented)
    
    interval - (undocumented)
    
    task - (undocumented)
    
    Returns:
    
    A Cancellable that allows cancelling the timer. Cancelling is best effort, if the event has been already enqueued it will not have an effect.
  - scheduleOnce
```
public Cancellable scheduleOnce(scala.concurrent.duration.FiniteDuration delay,
                                java.lang.Runnable task)
```
    Description copied from class: Materializer
    
    Interface for operators that need timer services for their functionality. Schedules a single task with the given delay.
    
    Specified by:
    
    scheduleOnce in class Materializer
    
    Parameters:
    
    delay - (undocumented)
    
    task - (undocumented)
    
    Returns:
    
    A Cancellable that allows cancelling the timer. Cancelling is best effort, if the event has been already enqueued it will not have an effect.
  - materialize
```
public <Mat> Mat materialize(Graph<ClosedShape,Mat> _runnableGraph)
```
    Description copied from class: ExtendedActorMaterializer
    
    INTERNAL API
    
    Specified by:
    
    materialize in class ExtendedActorMaterializer
    
    Parameters:
    
    _runnableGraph - (undocumented)
    
    Returns:
    
    (undocumented)
  - materialize
```
public <Mat> Mat materialize(Graph<ClosedShape,Mat> _runnableGraph,
                             Attributes defaultAttributes)
```
    Description copied from class: ExtendedActorMaterializer
    
    INTERNAL API
    
    Specified by:
    
    materialize in class ExtendedActorMaterializer
    
    Parameters:
    
    _runnableGraph - (undocumented)
    
    defaultAttributes - (undocumented)
    
    Returns:
    
    (undocumented)
  - materialize
```
public <Mat> Mat materialize(Graph<ClosedShape,Mat> graph,
                             Attributes defaultAttributes,
                             Phase<java.lang.Object> defaultPhase,
                             scala.collection.immutable.Map<IslandTag,Phase<java.lang.Object>> phases)
```
    Description copied from class: ExtendedActorMaterializer
    
    INTERNAL API
    
    Specified by:
    
    materialize in class ExtendedActorMaterializer
  - makeLogger
```
public LoggingAdapter makeLogger(java.lang.Class<?> logSource)
```
    Specified by:
    
    makeLogger in interface MaterializerLoggingProvider
  - copy
```
public PhasedFusingActorMaterializer copy(ActorSystem system,
                                          ActorMaterializerSettings settings,
                                          Dispatchers dispatchers,
                                          ActorRef supervisor,
                                          java.util.concurrent.atomic.AtomicBoolean haveShutDown,
                                          SeqActorName flowNames)
```
  - copy$default$1
```
public ActorSystem copy$default$1()
```
  - copy$default$2
```
public ActorMaterializerSettings copy$default$2()
```
  - copy$default$3
```
public Dispatchers copy$default$3()
```
  - copy$default$4
```
public ActorRef copy$default$4()
```
  - copy$default$5
```
public java.util.concurrent.atomic.AtomicBoolean copy$default$5()
```
  - copy$default$6
```
public SeqActorName copy$default$6()
```
  - productPrefix
```
public java.lang.String productPrefix()
```
    Specified by:
    
    productPrefix in interface scala.Product
  - productArity
```
public int productArity()
```
    Specified by:
    
    productArity in interface scala.Product
  - productElement
```
public java.lang.Object productElement(int x$1)
```
    Specified by:
    
    productElement in interface scala.Product
  - productIterator
```
public scala.collection.Iterator<java.lang.Object> productIterator()
```
    Specified by:
    
    productIterator in interface scala.Product
  - canEqual
```
public boolean canEqual(java.lang.Object x$1)
```
    Specified by:
    
    canEqual in interface scala.Equals
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class java.lang.Object
  - toString
```
public java.lang.String toString()
```
    Overrides:
    
    toString in class java.lang.Object
  - equals
```
public boolean equals(java.lang.Object x$1)
```
    Specified by:
    
    equals in interface scala.Equals
    
    Overrides:
    
    equals in class java.lang.Object

Class PhasedFusingActorMaterializer

Constructor Summary

Method Summary

Methods inherited from class akka.stream.impl.ExtendedActorMaterializer

Methods inherited from class akka.stream.ActorMaterializer

Methods inherited from class akka.stream.Materializer

Methods inherited from class java.lang.Object

Constructor Detail

PhasedFusingActorMaterializer

Method Detail

Debug

DefaultPhase

DefaultPhases

apply

apply

unapply

system

settings

dispatchers

supervisor

haveShutDown

flowNames

logger

shutdown

isShutdown

withNamePrefix

defaultAttributes

executionContext

schedulePeriodically

scheduleOnce

materialize

materialize

materialize

makeLogger

copy

copy$default$1

copy$default$2

copy$default$3

copy$default$4

copy$default$5

copy$default$6

productPrefix

productArity

productElement

productIterator

canEqual

hashCode

toString

equals