public class ActorMaterializerImpl extends ExtendedActorMaterializer implements scala.Product, scala.Serializable
Constructor and Description |
---|
ActorMaterializerImpl(ActorSystem system,
ActorMaterializerSettings settings,
Dispatchers dispatchers,
ActorRef supervisor,
java.util.concurrent.atomic.AtomicBoolean haveShutDown,
SeqActorName flowNames) |
Modifier and Type | Method and Description |
---|---|
static ActorRef |
actorOf(MaterializationContext context,
Props props) |
protected static ActorRef |
actorOf(Props props,
java.lang.String name,
java.lang.String dispatcher) |
abstract static boolean |
canEqual(java.lang.Object that) |
Dispatchers |
dispatchers() |
ActorMaterializerSettings |
effectiveSettings(Attributes opAttr) |
abstract static boolean |
equals(java.lang.Object that) |
scala.concurrent.ExecutionContextExecutor |
executionContext() |
SeqActorName |
flowNames() |
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) |
<Mat> Mat |
materialize(Graph<ClosedShape,Mat> _runnableGraph,
Attributes initialAttributes) |
<Mat> Mat |
materialize(Graph<ClosedShape,Mat> _runnableGraph,
scala.Function1<GraphInterpreterShell,ActorRef> subflowFuser)
INTERNAL API
|
<Mat> Mat |
materialize(Graph<ClosedShape,Mat> _runnableGraph,
scala.Function1<GraphInterpreterShell,ActorRef> subflowFuser,
Attributes initialAttributes)
INTERNAL API
|
abstract static int |
productArity() |
abstract static java.lang.Object |
productElement(int n) |
static scala.collection.Iterator<java.lang.Object> |
productIterator() |
static java.lang.String |
productPrefix() |
Cancellable |
scheduleOnce(scala.concurrent.duration.FiniteDuration delay,
java.lang.Runnable task) |
Cancellable |
schedulePeriodically(scala.concurrent.duration.FiniteDuration initialDelay,
scala.concurrent.duration.FiniteDuration interval,
java.lang.Runnable task) |
ActorMaterializerSettings |
settings() |
void |
shutdown()
Shuts down this materializer and all the stages that have been materialized through this materializer.
|
ActorRef |
supervisor()
INTERNAL API
|
ActorSystem |
system()
INTERNAL API
|
ActorMaterializerImpl |
withNamePrefix(java.lang.String name) |
actorOf, actorOf
apply, apply, apply, create, create, create, systemMaterializer
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public ActorMaterializerImpl(ActorSystem system, ActorMaterializerSettings settings, Dispatchers dispatchers, ActorRef supervisor, java.util.concurrent.atomic.AtomicBoolean haveShutDown, SeqActorName flowNames)
public static ActorRef actorOf(MaterializationContext context, Props props)
protected static ActorRef actorOf(Props props, java.lang.String name, java.lang.String dispatcher)
public abstract static boolean canEqual(java.lang.Object that)
public abstract static boolean equals(java.lang.Object that)
public abstract static java.lang.Object productElement(int n)
public abstract static int productArity()
public static scala.collection.Iterator<java.lang.Object> productIterator()
public static java.lang.String productPrefix()
public ActorSystem system()
ActorMaterializer
system
in class ActorMaterializer
public ActorMaterializerSettings settings()
settings
in class ActorMaterializer
public Dispatchers dispatchers()
public ActorRef supervisor()
ExtendedActorMaterializer
supervisor
in class ExtendedActorMaterializer
public java.util.concurrent.atomic.AtomicBoolean haveShutDown()
public SeqActorName flowNames()
public LoggingAdapter logger()
ExtendedActorMaterializer
logger
in class ExtendedActorMaterializer
public void shutdown()
ActorMaterializer
shutdown
in class ActorMaterializer
public boolean isShutdown()
ActorMaterializer
isShutdown
in class ActorMaterializer
public ActorMaterializerImpl withNamePrefix(java.lang.String name)
withNamePrefix
in class ExtendedActorMaterializer
public ActorMaterializerSettings effectiveSettings(Attributes opAttr)
effectiveSettings
in class ActorMaterializer
public Cancellable schedulePeriodically(scala.concurrent.duration.FiniteDuration initialDelay, scala.concurrent.duration.FiniteDuration interval, java.lang.Runnable task)
schedulePeriodically
in class ActorMaterializer
public Cancellable scheduleOnce(scala.concurrent.duration.FiniteDuration delay, java.lang.Runnable task)
scheduleOnce
in class ActorMaterializer
public <Mat> Mat materialize(Graph<ClosedShape,Mat> _runnableGraph)
materialize
in class ActorMaterializer
public <Mat> Mat materialize(Graph<ClosedShape,Mat> _runnableGraph, Attributes initialAttributes)
materialize
in class ActorMaterializer
public <Mat> Mat materialize(Graph<ClosedShape,Mat> _runnableGraph, scala.Function1<GraphInterpreterShell,ActorRef> subflowFuser)
ExtendedActorMaterializer
materialize
in class ExtendedActorMaterializer
_runnableGraph
- (undocumented)subflowFuser
- (undocumented)public <Mat> Mat materialize(Graph<ClosedShape,Mat> _runnableGraph, scala.Function1<GraphInterpreterShell,ActorRef> subflowFuser, Attributes initialAttributes)
ExtendedActorMaterializer
materialize
in class ExtendedActorMaterializer
_runnableGraph
- (undocumented)subflowFuser
- (undocumented)initialAttributes
- (undocumented)public LoggingAdapter makeLogger(java.lang.Class<?> logSource)
makeLogger
in interface MaterializerLoggingProvider
makeLogger
in class ActorMaterializer
public scala.concurrent.ExecutionContextExecutor executionContext()
executionContext
in class ActorMaterializer