Class GroupedWeightedWithin<T>

  • All Implemented Interfaces:
    Graph<FlowShape<T,​scala.collection.immutable.Seq<T>>,​NotUsed>

    public final class GroupedWeightedWithin<T>
    extends GraphStage<FlowShape<T,​scala.collection.immutable.Seq<T>>>
    INTERNAL API
    • Constructor Detail

      • GroupedWeightedWithin

        public GroupedWeightedWithin​(long maxWeight,
                                     scala.Function1<T,​java.lang.Object> costFn,
                                     scala.concurrent.duration.FiniteDuration interval)
    • Method Detail

      • groupedWeightedWithinTimer

        public static java.lang.String groupedWeightedWithinTimer()
      • 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)
      • withAttributes

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

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

        public long maxWeight()
      • interval

        public scala.concurrent.duration.FiniteDuration interval()
      • out

        public Outlet<scala.collection.immutable.Seq<T>> out()
      • shape

        public FlowShape<T,​scala.collection.immutable.Seq<T>> shape()
        Description copied from interface: Graph
        The shape of a graph is all that is externally visible: its inlets and outlets.
        Returns:
        (undocumented)