Package org.apache.pekko.stream

Class UniformFanInShape<T,O>

java.lang.Object

org.apache.pekko.stream.Shape

org.apache.pekko.stream.FanInShape<O>

org.apache.pekko.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 org.apache.pekko.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, String name)
UniformFanInShape(int n, FanInShape.Init<O> _init)
UniformFanInShape(Outlet<O> outlet, Inlet<T>[] inlets)

Method Summary

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, List<Inlet<I>> inlets)	Java API
UniformFanInShape<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)
final scala.collection.immutable.Seq<Inlet<T>>	inlets()
int	n()

Methods inherited from class org.apache.pekko.stream.FanInShape

newInlet, out, outlets

Methods inherited from class org.apache.pekko.stream.Shape

getInlets, getOutlets, hasOnePort, hasSamePortsAndShapeAs, hasSamePortsAs, requireSamePortsAndShapeAs, requireSamePortsAs

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

UniformFanInShape

public UniformFanInShape(int n,
 FanInShape.Init<O> _init)

UniformFanInShape

public UniformFanInShape(int n)

UniformFanInShape

public UniformFanInShape(int n,
 String name)

UniformFanInShape

public UniformFanInShape(Outlet<O> outlet,
 Inlet<T>[] inlets)

Method Details

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,
 List<Inlet<I>> inlets)

Java API

n

public int n()

construct

protected FanInShape<O> construct(FanInShape.Init<O> init)

Specified by:

construct in class FanInShape<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 class FanInShape<O>

inlets

public final scala.collection.immutable.Seq<Inlet<T>> inlets()

in

public Inlet<T> in(int n)