Class Throttle<T>

    • Constructor Detail

      • Throttle

        public Throttle​(int cost,
                        scala.concurrent.duration.FiniteDuration per,
                        int maximumBurst,
                        scala.Function1<T,​java.lang.Object> costCalculation,
                        ThrottleMode mode)
    • Method Detail

      • AutomaticMaximumBurst

        public static final int AutomaticMaximumBurst()
      • named

        public static Graph<S,​M> named​(java.lang.String name)
      • async

        public static Graph<S,​M> async()
      • async

        public static Graph<S,​M> async​(java.lang.String dispatcher)
      • async

        public static Graph<S,​M> async​(java.lang.String dispatcher,
                                             int inputBufferSize)
      • addAttributes

        public static Graph<S,​M> addAttributes​(Attributes attr)
      • initialAttributes

        protected static Attributes initialAttributes()
      • withAttributes

        public static final Graph<S,​M> withAttributes​(Attributes attr)
      • createLogicAndMaterializedValue

        public static final scala.Tuple2<GraphStageLogic,​NotUsed> createLogicAndMaterializedValue​(Attributes inheritedAttributes)
      • in

        public static Inlet<T> in()
      • out

        public static Outlet<T> out()
      • shape

        public static FlowShape<T,​T> shape()
      • cost

        public int cost()
      • per

        public scala.concurrent.duration.FiniteDuration per()
      • maximumBurst

        public int maximumBurst()
      • costCalculation

        public scala.Function1<T,​java.lang.Object> costCalculation()
      • effectiveMaximumBurst

        public long effectiveMaximumBurst()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object