Class GroupBy<T,​K>

    • Constructor Detail

      • GroupBy

        public GroupBy​(int maxSubstreams,
                       scala.Function1<T,​K> keyFor,
                       boolean allowClosedSubstreamRecreation)
    • Method Detail

      • $lessinit$greater$default$3

        public static <T,​K> boolean $lessinit$greater$default$3()
      • 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)
      • maxSubstreams

        public int maxSubstreams()
      • keyFor

        public scala.Function1<T,​K> keyFor()
      • allowClosedSubstreamRecreation

        public boolean allowClosedSubstreamRecreation()
      • shape

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

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