Class ActorMaterializer$


  • public class ActorMaterializer$
    extends java.lang.Object
    • 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)
        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.

        Parameters:
        materializerSettings - (undocumented)
        namePrefix - (undocumented)
        actorSystem - (undocumented)
        Returns:
        (undocumented)
      • 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$3

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