Class 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.

    • Constructor Detail

      • ActorMaterializer

        public ActorMaterializer()
    • Method Detail

      • apply$default$2

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

        public static <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 static <T> scala.Option<java.lang.String> boundToActor$default$3()