Package org.apache.pekko.stream
Class UniformFanOutShape<I,O>
- java.lang.Object
-
- org.apache.pekko.stream.Shape
-
- org.apache.pekko.stream.FanOutShape<I>
-
- org.apache.pekko.stream.UniformFanOutShape<I,O>
-
public class UniformFanOutShape<I,O> extends FanOutShape<I>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.pekko.stream.FanOutShape
FanOutShape.Init<I>, FanOutShape.Name<I>, FanOutShape.Name$, FanOutShape.Ports<I>, FanOutShape.Ports$
-
-
Constructor Summary
Constructors Constructor Description UniformFanOutShape(int n)
UniformFanOutShape(int n, java.lang.String name)
UniformFanOutShape(int n, FanOutShape.Init<I> _init)
UniformFanOutShape(Inlet<I> inlet, Outlet<O>[] outlets)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static <I,O>
UniformFanOutShape<I,O>apply(Inlet<I> inlet, scala.collection.immutable.Seq<Outlet<O>> outlets)
protected FanOutShape<I>
construct(FanOutShape.Init<I> init)
UniformFanOutShape<I,O>
deepCopy()
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.Outlet<O>
out(int n)
Outlet<O>[]
outArray()
Deprecated.use 'outlets' or 'out(id)' instead.scala.collection.immutable.Seq<Outlet<O>>
outlets()
-
Methods inherited from class org.apache.pekko.stream.FanOutShape
in, inlets, newOutlet
-
Methods inherited from class org.apache.pekko.stream.Shape
getInlets, getOutlets, hasOnePort, hasSamePortsAndShapeAs, hasSamePortsAs, requireSamePortsAndShapeAs, requireSamePortsAs
-
-
-
-
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)
-
-
Method Detail
-
apply
public static <I,O> UniformFanOutShape<I,O> apply(Inlet<I> inlet, scala.collection.immutable.Seq<Outlet<O>> outlets)
-
construct
protected FanOutShape<I> construct(FanOutShape.Init<I> init)
- Specified by:
construct
in classFanOutShape<I>
-
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 classFanOutShape<I>
-
outArray
public Outlet<O>[] outArray()
Deprecated.use 'outlets' or 'out(id)' instead. Since Akka 2.5.5.
-
-