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

Modifier and Type	Method	Description
ActorRef	actorOf(Props props, java.lang.String name)	INTERNAL API
ActorRef	actorOf(MaterializationContext context, Props props)	INTERNAL API
abstract LoggingAdapter	logger()	INTERNAL API
abstract <Mat> Mat	materialize(Graph<ClosedShape,Mat> _runnableGraph)	INTERNAL API
abstract <Mat> Mat	materialize(Graph<ClosedShape,Mat> _runnableGraph, Attributes defaultAttributes)	INTERNAL API
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
abstract ActorRef	supervisor()	INTERNAL API
abstract 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

Constructor Detail

ExtendedActorMaterializer

public ExtendedActorMaterializer()

Method Detail

actorOf

public ActorRef actorOf(MaterializationContext context,
                        Props props)

INTERNAL API

Specified by:

actorOf in class ActorMaterializer

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 class ActorMaterializer

Returns:

(undocumented)

materialize

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

INTERNAL API

Specified by:

materialize in class Materializer

Parameters:

_runnableGraph - (undocumented)

Returns:

(undocumented)

materialize

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

INTERNAL API

Specified by:

materialize in class Materializer

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 class ActorMaterializer

Returns:

(undocumented)

withNamePrefix

public abstract ExtendedActorMaterializer withNamePrefix(java.lang.String name)

Specified by:

withNamePrefix in class Materializer