object ActorMaterializer
- Source
- ActorMaterializer.scala
- Alphabetic
- By Inheritance
- ActorMaterializer
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
def
apply[T](materializerSettings: Option[ActorMaterializerSettings] = None, namePrefix: Option[String] = None)(implicit actorSystem: ActorSystem[T]): ActorMaterializer
Creates an
ActorMaterializer
which will execute every step of a transformation pipeline within its own akka.actor.Actor.Creates an
ActorMaterializer
which will execute every step of a transformation pipeline within its own akka.actor.Actor. The required akka.actor.typed.ActorSystem will be used to create one actor that in turn creates actors for the transformation steps.The materializer's akka.stream.ActorMaterializerSettings will be obtained from the configuration of the
context
's underlying akka.actor.typed.ActorSystem.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
. -
def
boundToActor[T](ctx: ActorContext[T], materializerSettings: Option[ActorMaterializerSettings] = None, namePrefix: Option[String] = None): ActorMaterializer
Creates an
ActorMaterializer
which will execute every step of a transformation pipeline within its own akka.actor.Actor.Creates an
ActorMaterializer
which will execute every step of a transformation pipeline within its own akka.actor.Actor. The lifecycle of the materialized streams will be bound to the lifecycle of the provided akka.actor.typed.scaladsl.ActorContextThe materializer's akka.stream.ActorMaterializerSettings will be obtained from the configuration of the
context
's underlying akka.actor.typed.ActorSystem.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
.