Package akka.stream
Class UniformFanInShape<T,O>
- java.lang.Object
-
- akka.stream.Shape
-
- akka.stream.FanInShape<O>
-
- akka.stream.UniformFanInShape<T,O>
-
- Direct Known Subclasses:
MergePreferred.MergePreferredShape
public class UniformFanInShape<T,O> extends FanInShape<O>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.stream.FanInShape
FanInShape.Init<O>, FanInShape.Name<O>, FanInShape.Name$, FanInShape.Ports<O>, FanInShape.Ports$
-
-
Constructor Summary
Constructors Constructor Description UniformFanInShape(int n)
UniformFanInShape(int n, FanInShape.Init<O> _init)
UniformFanInShape(int n, java.lang.String name)
UniformFanInShape(Outlet<O> outlet, Inlet<T>[] inlets)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static <I,O>
UniformFanInShape<I,O>apply(Outlet<O> outlet, scala.collection.immutable.Seq<Inlet<I>> inlets)
protected FanInShape<O>
construct(FanInShape.Init<O> init)
static <I,O>
UniformFanInShape<I,O>create(Outlet<O> outlet, java.util.List<Inlet<I>> inlets)
Java APIUniformFanInShape<T,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.Inlet<T>
in(int n)
scala.collection.immutable.Seq<Inlet<T>>
inlets()
scala.collection.immutable.IndexedSeq<Inlet<T>>
inSeq()
Deprecated.Use 'inlets' or 'in(id)' instead.int
n()
-
Methods inherited from class akka.stream.FanInShape
newInlet, out, outlets
-
Methods inherited from class akka.stream.Shape
getInlets, getOutlets, hasOnePort, hasSamePortsAndShapeAs, hasSamePortsAs, requireSamePortsAndShapeAs, requireSamePortsAs
-
-
-
-
Constructor Detail
-
UniformFanInShape
public UniformFanInShape(int n, FanInShape.Init<O> _init)
-
UniformFanInShape
public UniformFanInShape(int n)
-
UniformFanInShape
public UniformFanInShape(int n, java.lang.String name)
-
-
Method Detail
-
apply
public static <I,O> UniformFanInShape<I,O> apply(Outlet<O> outlet, scala.collection.immutable.Seq<Inlet<I>> inlets)
-
create
public static <I,O> UniformFanInShape<I,O> create(Outlet<O> outlet, java.util.List<Inlet<I>> inlets)
Java API
-
n
public int n()
-
construct
protected FanInShape<O> construct(FanInShape.Init<O> init)
- Specified by:
construct
in classFanInShape<O>
-
deepCopy
public UniformFanInShape<T,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 classFanInShape<O>
-
inSeq
public scala.collection.immutable.IndexedSeq<Inlet<T>> inSeq()
Deprecated.Use 'inlets' or 'in(id)' instead. Since 2.5.5.
-
-