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:

ActorMaterializerImpl

public abstract class ExtendedActorMaterializer
extends ActorMaterializer

ExtendedActorMaterializer used by subtypes which materializer using GraphInterpreterShell

Constructor Summary

Constructors

Constructor and Description
ExtendedActorMaterializer()

Method Summary

Modifier and Type	Method and Description
ActorRef	actorOf(MaterializationContext context, Props props) INTERNAL API
protected ActorRef	actorOf(Props props, java.lang.String name, java.lang.String dispatcher) INTERNAL API
abstract LoggingAdapter	logger() INTERNAL API
abstract <Mat> Mat	materialize(Graph<ClosedShape,Mat> _runnableGraph, scala.Function1<GraphInterpreterShell,ActorRef> subflowFuser) INTERNAL API
abstract <Mat> Mat	materialize(Graph<ClosedShape,Mat> _runnableGraph, scala.Function1<GraphInterpreterShell,ActorRef> subflowFuser, Attributes initialAttributes) INTERNAL API
abstract ActorRef	supervisor() INTERNAL API
abstract ExtendedActorMaterializer	withNamePrefix(java.lang.String name)

Methods inherited from class akka.stream.ActorMaterializer

apply, apply, apply, create, create, create, effectiveSettings, executionContext, isShutdown, makeLogger, materialize, materialize, scheduleOnce, schedulePeriodically, settings, shutdown, system, systemMaterializer

Methods inherited from class akka.stream.Materializer

executionContext, materialize, materialize, 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

withNamePrefix

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

Specified by:

withNamePrefix in class ActorMaterializer

materialize

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

INTERNAL API

Parameters:

_runnableGraph - (undocumented)

subflowFuser - (undocumented)

Returns:

(undocumented)

materialize

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

INTERNAL API

Parameters:

_runnableGraph - (undocumented)

subflowFuser - (undocumented)

initialAttributes - (undocumented)

Returns:

(undocumented)

actorOf

public ActorRef actorOf(MaterializationContext context,
                        Props props)

INTERNAL API

Specified by:

actorOf in class ActorMaterializer

Parameters:

context - (undocumented)

props - (undocumented)

Returns:

(undocumented)

actorOf

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

INTERNAL API

Parameters:

props - (undocumented)

name - (undocumented)

dispatcher - (undocumented)

Returns:

(undocumented)

logger

public abstract LoggingAdapter logger()

INTERNAL API

Specified by:

logger in class ActorMaterializer

Returns:

(undocumented)

supervisor

public abstract ActorRef supervisor()

INTERNAL API

Specified by:

supervisor in class ActorMaterializer

Returns:

(undocumented)