Class ActorMaterializer$
- java.lang.Object
-
- akka.stream.ActorMaterializer$
-
public class ActorMaterializer$ extends java.lang.Object
Scala API: Creates an ActorMaterializer that can materialize stream blueprints as running streams.The required
ActorRefFactory
(which can be either anActorSystem
or anActorContext
) 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 thecontext
's underlyingActorSystem
.The
namePrefix
is used as the first part of the names of the actors running the processing steps. The defaultnamePrefix
is"flow"
. The actor names are built up ofnamePrefix-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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ActorMaterializer
apply(ActorMaterializerSettings materializerSettings, ActorRefFactory context)
Scala API: Creates an ActorMaterializer that can materialize stream blueprints as running streams.ActorMaterializer
apply(ActorMaterializerSettings materializerSettings, java.lang.String namePrefix, ActorRefFactory context)
Scala API: Creates an ActorMaterializer that can materialize stream blueprints as running streams.ActorMaterializer
apply(scala.Option<ActorMaterializerSettings> materializerSettings, scala.Option<java.lang.String> namePrefix, ActorRefFactory context)
scala.Option<ActorMaterializerSettings>
apply$default$1()
scala.Option<java.lang.String>
apply$default$2()
ActorMaterializer
create(ActorRefFactory context)
Java API: Creates an ActorMaterializer that can materialize stream blueprints as running streams.ActorMaterializer
create(ActorMaterializerSettings settings, ActorRefFactory context)
Java API: Creates an ActorMaterializer that can materialize stream blueprints as running streams.ActorMaterializer
create(ActorMaterializerSettings settings, ActorRefFactory context, java.lang.String namePrefix)
Java API: Creates an ActorMaterializer that can materialize stream blueprints as running streams.ActorMaterializer
systemMaterializer(ActorMaterializerSettings materializerSettings, java.lang.String namePrefix, ExtendedActorSystem system)
INTERNAL API: Creates theStreamSupervisor
as a system actor.
-
-
-
Field Detail
-
MODULE$
public static final ActorMaterializer$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
apply
public ActorMaterializer apply(scala.Option<ActorMaterializerSettings> materializerSettings, scala.Option<java.lang.String> namePrefix, ActorRefFactory context)
-
apply
public ActorMaterializer apply(ActorMaterializerSettings materializerSettings, java.lang.String namePrefix, ActorRefFactory context)
Scala API: Creates an ActorMaterializer that can materialize stream blueprints as running streams.The required
ActorRefFactory
(which can be either anActorSystem
or anActorContext
) will be used to create these actors, therefore it is *forbidden* to pass this object to another actor if the factory is an ActorContext.The
namePrefix
is used as the first part of the names of the actors running the processing steps. The defaultnamePrefix
is"flow"
. The actor names are built up ofnamePrefix-flowNumber-flowStepNumber-stepName
.- Parameters:
materializerSettings
- (undocumented)namePrefix
- (undocumented)context
- (undocumented)- Returns:
- (undocumented)
-
apply
public ActorMaterializer apply(ActorMaterializerSettings materializerSettings, ActorRefFactory context)
Scala API: Creates an ActorMaterializer that can materialize stream blueprints as running streams.The required
ActorRefFactory
(which can be either anActorSystem
or anActorContext
) will be used to create these actors, therefore it is *forbidden* to pass this object to another actor if the factory is an ActorContext.The
namePrefix
is used as the first part of the names of the actors running the processing steps. The defaultnamePrefix
is"flow"
. The actor names are built up ofnamePrefix-flowNumber-flowStepNumber-stepName
.- Parameters:
materializerSettings
- (undocumented)context
- (undocumented)- Returns:
- (undocumented)
-
apply$default$1
public scala.Option<ActorMaterializerSettings> apply$default$1()
-
apply$default$2
public scala.Option<java.lang.String> apply$default$2()
-
systemMaterializer
public ActorMaterializer systemMaterializer(ActorMaterializerSettings materializerSettings, java.lang.String namePrefix, ExtendedActorSystem system)
INTERNAL API: Creates theStreamSupervisor
as a system actor.- Parameters:
materializerSettings
- (undocumented)namePrefix
- (undocumented)system
- (undocumented)- Returns:
- (undocumented)
-
create
public ActorMaterializer create(ActorRefFactory context)
Java API: Creates an ActorMaterializer that can materialize stream blueprints as running streams.The required
ActorRefFactory
(which can be either anActorSystem
or anActorContext
) will be used to create these actors, therefore it is *forbidden* to pass this object to another actor if the factory is an ActorContext.Defaults the actor name prefix used to name actors running the processing steps to
"flow"
. The actor names are built up ofnamePrefix-flowNumber-flowStepNumber-stepName
.- Parameters:
context
- (undocumented)- Returns:
- (undocumented)
-
create
public ActorMaterializer create(ActorMaterializerSettings settings, ActorRefFactory context)
Java API: Creates an ActorMaterializer that can materialize stream blueprints as running streams.The required
ActorRefFactory
(which can be either anActorSystem
or anActorContext
) will be used to create one actor that in turn creates actors for the transformation steps.- Parameters:
settings
- (undocumented)context
- (undocumented)- Returns:
- (undocumented)
-
create
public ActorMaterializer create(ActorMaterializerSettings settings, ActorRefFactory context, java.lang.String namePrefix)
Java API: Creates an ActorMaterializer that can materialize stream blueprints as running streams.The required
ActorRefFactory
(which can be either anActorSystem
or anActorContext
) will be used to create these actors, therefore it is *forbidden* to pass this object to another actor if the factory is an ActorContext.The
namePrefix
is used as the first part of the names of the actors running the processing steps. The defaultnamePrefix
is"flow"
. The actor names are built up ofnamePrefix-flowNumber-flowStepNumber-stepName
.- Parameters:
settings
- (undocumented)context
- (undocumented)namePrefix
- (undocumented)- Returns:
- (undocumented)
-
-