Package akka.stream.impl
Class ExtendedActorMaterializer
- java.lang.Object
-
- akka.stream.Materializer
-
- akka.stream.ActorMaterializer
-
- akka.stream.impl.ExtendedActorMaterializer
-
- All Implemented Interfaces:
MaterializerLoggingProvider
- Direct Known Subclasses:
PhasedFusingActorMaterializer
public abstract class ExtendedActorMaterializer extends ActorMaterializer
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description ExtendedActorMaterializer()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description ActorRef
actorOf(Props props, java.lang.String name)
INTERNAL APIActorRef
actorOf(MaterializationContext context, Props props)
INTERNAL APIabstract LoggingAdapter
logger()
INTERNAL APIabstract <Mat> Mat
materialize(Graph<ClosedShape,Mat> _runnableGraph)
INTERNAL APIabstract <Mat> Mat
materialize(Graph<ClosedShape,Mat> _runnableGraph, Attributes defaultAttributes)
INTERNAL APIabstract <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 APIabstract ActorRef
supervisor()
INTERNAL APIabstract ExtendedActorMaterializer
withNamePrefix(java.lang.String name)
-
Methods inherited from class akka.stream.ActorMaterializer
apply, apply, apply, apply$default$1, apply$default$2, create, create, create, isShutdown, settings, shutdown, system, systemMaterializer
-
Methods inherited from class akka.stream.Materializer
executionContext, matFromSystem, scheduleOnce, schedulePeriodically
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.stream.MaterializerLoggingProvider
makeLogger
-
-
-
-
Method Detail
-
actorOf
public ActorRef actorOf(MaterializationContext context, Props props)
INTERNAL API- Specified by:
actorOf
in classActorMaterializer
- Parameters:
context
- (undocumented)props
- (undocumented)- Returns:
- (undocumented)
-
actorOf
public ActorRef actorOf(Props props, java.lang.String name)
INTERNAL API- Parameters:
props
- (undocumented)name
- (undocumented)- Returns:
- (undocumented)
-
logger
public abstract LoggingAdapter logger()
INTERNAL API- Specified by:
logger
in classActorMaterializer
- Returns:
- (undocumented)
-
materialize
public abstract <Mat> Mat materialize(Graph<ClosedShape,Mat> _runnableGraph)
INTERNAL API- Specified by:
materialize
in classMaterializer
- Parameters:
_runnableGraph
- (undocumented)- Returns:
- (undocumented)
-
materialize
public abstract <Mat> Mat materialize(Graph<ClosedShape,Mat> _runnableGraph, Attributes defaultAttributes)
INTERNAL API- Specified by:
materialize
in classMaterializer
- Parameters:
_runnableGraph
- (undocumented)defaultAttributes
- (undocumented)- Returns:
- (undocumented)
-
materialize
public abstract <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
-
supervisor
public abstract ActorRef supervisor()
INTERNAL API- Specified by:
supervisor
in classActorMaterializer
- Returns:
- (undocumented)
-
withNamePrefix
public abstract ExtendedActorMaterializer withNamePrefix(java.lang.String name)
- Specified by:
withNamePrefix
in classMaterializer
-
-