Class ExtendedActorMaterializer

    • Constructor Detail

      • ExtendedActorMaterializer

        public ExtendedActorMaterializer()
    • Method Detail

      • actorOf

        public ActorRef actorOf​(Props props,
                                java.lang.String name)
        INTERNAL API
        Parameters:
        props - (undocumented)
        name - (undocumented)
        Returns:
        (undocumented)
      • materialize

        public abstract <Mat> Mat materialize​(Graph<ClosedShape,​Mat> _runnableGraph)
        INTERNAL API
        Specified by:
        materialize in class Materializer
        Parameters:
        _runnableGraph - (undocumented)
        Returns:
        (undocumented)
      • materialize

        public abstract <Mat> Mat materialize​(Graph<ClosedShape,​Mat> _runnableGraph,
                                              Attributes defaultAttributes)
        INTERNAL API
        Specified by:
        materialize in class Materializer
        Parameters:
        _runnableGraph - (undocumented)
        defaultAttributes - (undocumented)
        Returns:
        (undocumented)
      • materialize

        public abstract <Mat> Mat materialize​(Graph<ClosedShape,​Mat> graph,
                                              Attributes defaultAttributes,
                                              Phase<java.lang.Object> defaultPhase,
                                              scala.collection.immutable.Map<IslandTag,​Phase<java.lang.Object>> phases)
        INTERNAL API
      • withNamePrefix

        public abstract ExtendedActorMaterializer withNamePrefix​(java.lang.String name)
        Description copied from class: Materializer
        The namePrefix shall be used for deriving the names of processing entities that are created during materialization. This is meant to aid logging and failure reporting both during materialization and while the stream is running.
        Specified by:
        withNamePrefix in class Materializer
        Parameters:
        name - (undocumented)
        Returns:
        (undocumented)