Package akka.stream

Class UniformFanOutShape<I,​O>


  • public class UniformFanOutShape<I,​O>
    extends FanOutShape<I>
    • Constructor Detail

      • UniformFanOutShape

        public UniformFanOutShape​(int n,
                                  FanOutShape.Init<I> _init)
      • UniformFanOutShape

        public UniformFanOutShape​(int n)
      • UniformFanOutShape

        public UniformFanOutShape​(int n,
                                  java.lang.String name)
      • UniformFanOutShape

        public UniformFanOutShape​(Inlet<I> inlet,
                                  Outlet<O>[] outlets)
    • Method Detail

      • getInlets

        public static java.util.List<Inlet<?>> getInlets()
      • getOutlets

        public static java.util.List<Outlet<?>> getOutlets()
      • hasSamePortsAs

        public static boolean hasSamePortsAs​(Shape s)
      • hasSamePortsAndShapeAs

        public static boolean hasSamePortsAndShapeAs​(Shape s)
      • requireSamePortsAs

        public static void requireSamePortsAs​(Shape s)
      • requireSamePortsAndShapeAs

        public static void requireSamePortsAndShapeAs​(Shape s)
      • in

        public static final Inlet<I> in()
      • inlets

        public static final scala.collection.immutable.Seq<Inlet<I>> inlets()
      • newOutlet

        protected static <T> Outlet<T> newOutlet​(java.lang.String name)
      • deepCopy

        public UniformFanOutShape<I,​O> deepCopy()
        Description copied from class: Shape
        Create a copy of this Shape object, returning the same type as the original; this constraint can unfortunately not be expressed in the type system.
        Overrides:
        deepCopy in class FanOutShape<I>
        Returns:
        (undocumented)
      • outlets

        public final scala.collection.immutable.Seq<Outlet<O>> outlets()
      • outArray

        public Outlet<O>[] outArray()
        Deprecated.
        use 'outlets' or 'out(id)' instead. Since 2.5.5.
      • out

        public Outlet<O> out​(int n)