Package akka.stream

Class ActorAttributes.Dispatcher$

  • All Implemented Interfaces:
    java.io.Serializable, scala.Serializable
    Enclosing class:
    ActorAttributes

    public static class ActorAttributes.Dispatcher$
    extends java.lang.Object
    implements scala.Serializable
    See Also:
    Serialized Form
    • Constructor Detail

      • Dispatcher$

        public Dispatcher$()
    • Method Detail

      • resolve

        public java.lang.String resolve​(Attributes attributes,
                                        ActorMaterializerSettings settings)
        INTERNAL API Resolves the dispatcher's name with a fallback to the default blocking IO dispatcher. Note that IODispatcher.dispatcher is not used here as the config used to create ActorMaterializerSettings is not easily accessible, instead the name is taken from settings.blockingIoDispatcher
        Parameters:
        attributes - (undocumented)
        settings - (undocumented)
        Returns:
        (undocumented)
      • resolve

        public java.lang.String resolve​(MaterializationContext context)
        INTERNAL API Resolves the dispatcher name with a fallback to the default blocking IO dispatcher.
        Parameters:
        context - (undocumented)
        Returns:
        (undocumented)