akka.stream.impl

Class ActorMaterializerImpl

java.lang.Object

akka.stream.Materializer

akka.stream.ActorMaterializer

akka.stream.impl.ExtendedActorMaterializer

akka.stream.impl.ActorMaterializerImpl

All Implemented Interfaces:

MaterializerLoggingProvider, java.io.Serializable, scala.Equals, scala.Product

public class ActorMaterializerImpl
extends ExtendedActorMaterializer
implements scala.Product, scala.Serializable

INTERNAL API

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

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)

Methods inherited from class akka.stream.impl.ExtendedActorMaterializer

actorOf, actorOf

Methods inherited from class akka.stream.ActorMaterializer

apply, apply, apply, create, create, create, systemMaterializer

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

ActorMaterializerImpl

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

Method Detail

actorOf

public static ActorRef actorOf(MaterializationContext context,
                               Props props)

actorOf

protected static ActorRef actorOf(Props props,
                                  java.lang.String name,
                                  java.lang.String dispatcher)

canEqual

public abstract static boolean canEqual(java.lang.Object that)

equals

public abstract static boolean equals(java.lang.Object that)

productElement

public abstract static java.lang.Object productElement(int n)

productArity

public abstract static int productArity()

productIterator

public static scala.collection.Iterator<java.lang.Object> productIterator()

productPrefix

public static java.lang.String productPrefix()

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 stages that have been materialized through this materializer. After having shut down, this materializer cannot be used again. Any attempt to materialize stages 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 ActorMaterializerImpl withNamePrefix(java.lang.String name)

Specified by:

withNamePrefix in class ExtendedActorMaterializer

effectiveSettings

public ActorMaterializerSettings effectiveSettings(Attributes opAttr)

Specified by:

effectiveSettings in class ActorMaterializer

schedulePeriodically

public Cancellable schedulePeriodically(scala.concurrent.duration.FiniteDuration initialDelay,
                                        scala.concurrent.duration.FiniteDuration interval,
                                        java.lang.Runnable task)

Specified by:

schedulePeriodically in class ActorMaterializer

scheduleOnce

public Cancellable scheduleOnce(scala.concurrent.duration.FiniteDuration delay,
                                java.lang.Runnable task)

Specified by:

scheduleOnce in class ActorMaterializer

materialize

public <Mat> Mat materialize(Graph<ClosedShape,Mat> _runnableGraph)

Specified by:

materialize in class ActorMaterializer

materialize

public <Mat> Mat materialize(Graph<ClosedShape,Mat> _runnableGraph,
                             Attributes initialAttributes)

Specified by:

materialize in class ActorMaterializer

materialize

public <Mat> Mat materialize(Graph<ClosedShape,Mat> _runnableGraph,
                             scala.Function1<GraphInterpreterShell,ActorRef> subflowFuser)

Description copied from class: ExtendedActorMaterializer

INTERNAL API

Specified by:

materialize in class ExtendedActorMaterializer

Parameters:

_runnableGraph - (undocumented)

subflowFuser - (undocumented)

Returns:

(undocumented)

materialize

public <Mat> Mat materialize(Graph<ClosedShape,Mat> _runnableGraph,
                             scala.Function1<GraphInterpreterShell,ActorRef> subflowFuser,
                             Attributes initialAttributes)

Description copied from class: ExtendedActorMaterializer

INTERNAL API

Specified by:

materialize in class ExtendedActorMaterializer

Parameters:

_runnableGraph - (undocumented)

subflowFuser - (undocumented)

initialAttributes - (undocumented)

Returns:

(undocumented)

makeLogger

public LoggingAdapter makeLogger(java.lang.Class<?> logSource)

Specified by:

makeLogger in interface MaterializerLoggingProvider

Specified by:

makeLogger in class ActorMaterializer

executionContext

public scala.concurrent.ExecutionContextExecutor executionContext()

Specified by:

executionContext in class ActorMaterializer