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

ExtendedActorMaterializer used by subtypes which delegates in-island wiring to PhaseIslands

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)	The namePrefix shall be used for deriving the names of processing entities that are created during materialization.

Methods inherited from class akka.stream.ActorMaterializer

apply, apply, apply, apply$default$1, apply$default$2, create, create, create, create, isShutdown, settings, shutdown, system

Methods inherited from class akka.stream.Materializer

apply, apply, createMaterializer, createMaterializer, executionContext, matFromSystem, scheduleAtFixedRate, scheduleOnce, schedulePeriodically, scheduleWithFixedDelay

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

actorOf

public ActorRef actorOf(Props props,
                        java.lang.String name)

INTERNAL API

logger

public abstract LoggingAdapter logger()

INTERNAL API

Specified by:

logger in class ActorMaterializer

materialize

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

INTERNAL API

Specified by:

materialize in class Materializer

materialize

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

INTERNAL API

Specified by:

materialize in class Materializer

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

withNamePrefix

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

Description copied from class: Materializer

The namePrefix shall be used for deriving the names of processing entities that are created during materialization. This is meant to aid logging and failure reporting both during materialization and while the stream is running.

Specified by:

withNamePrefix in class Materializer