Package akka.stream.typed.scaladsl

Class ActorMaterializer$

java.lang.Object

akka.stream.typed.scaladsl.ActorMaterializer$

public class ActorMaterializer$
extends java.lang.Object

Creates an ActorMaterializer which will execute every step of a transformation pipeline within its own Actor. The required ActorSystem will be used to create one actor that in turn creates actors for the transformation steps.

The materializer's ActorMaterializerSettings will be obtained from the configuration of the context's underlying ActorSystem.

The namePrefix is used as the first part of the names of the actors running the processing steps. The default namePrefix is "flow". The actor names are built up of namePrefix-flowNumber-flowStepNumber-stepName.

Field Summary

Fields

Modifier and Type	Field	Description
static ActorMaterializer$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
ActorMaterializer$()

Method Summary

Modifier and Type	Method	Description
<T> ActorMaterializer	apply(scala.Option<ActorMaterializerSettings> materializerSettings, scala.Option<java.lang.String> namePrefix, ActorSystem<T> actorSystem)
<T> scala.Option<ActorMaterializerSettings>	apply$default$1()
<T> scala.Option<java.lang.String>	apply$default$2()
<T> ActorMaterializer	boundToActor(ActorContext<T> ctx, scala.Option<ActorMaterializerSettings> materializerSettings, scala.Option<java.lang.String> namePrefix)	Creates an ActorMaterializer which will execute every step of a transformation pipeline within its own Actor.
<T> scala.Option<ActorMaterializerSettings>	boundToActor$default$2()
<T> scala.Option<java.lang.String>	boundToActor$default$3()

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final ActorMaterializer$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

ActorMaterializer$

public ActorMaterializer$()

Method Detail

apply

public <T> ActorMaterializer apply(scala.Option<ActorMaterializerSettings> materializerSettings,
                                   scala.Option<java.lang.String> namePrefix,
                                   ActorSystem<T> actorSystem)

apply$default$1

public <T> scala.Option<ActorMaterializerSettings> apply$default$1()

apply$default$2

public <T> scala.Option<java.lang.String> apply$default$2()

boundToActor

public <T> ActorMaterializer boundToActor(ActorContext<T> ctx,
                                          scala.Option<ActorMaterializerSettings> materializerSettings,
                                          scala.Option<java.lang.String> namePrefix)

Creates an ActorMaterializer which will execute every step of a transformation pipeline within its own Actor. The lifecycle of the materialized streams will be bound to the lifecycle of the provided ActorContext

The materializer's ActorMaterializerSettings will be obtained from the configuration of the context's underlying ActorSystem.

The namePrefix is used as the first part of the names of the actors running the processing steps. The default namePrefix is "flow". The actor names are built up of namePrefix-flowNumber-flowStepNumber-stepName.

Parameters:

ctx - (undocumented)

materializerSettings - (undocumented)

namePrefix - (undocumented)

Returns:

(undocumented)

boundToActor$default$2

public <T> scala.Option<ActorMaterializerSettings> boundToActor$default$2()

boundToActor$default$3

public <T> scala.Option<java.lang.String> boundToActor$default$3()