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 and 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

Modifier and Type	Method and Description
static <I,O> UniformFanInShape<I,O>	apply(Outlet<O> outlet, scala.collection.Seq<Inlet<I>> inlets)
protected FanInShape<O>	construct(FanInShape.Init<O> init)
static FanInShape<O>	copyFromPorts(scala.collection.immutable.Seq<Inlet<?>> inlets, scala.collection.immutable.Seq<Outlet<?>> outlets)
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.
static java.util.List<Inlet<?>>	getInlets()
static java.util.List<Outlet<?>>	getOutlets()
static boolean	hasSamePortsAndShapeAs(Shape s)
static boolean	hasSamePortsAs(Shape s)
Inlet<T>	in(int n)
static scala.collection.immutable.Seq<Inlet<?>>	inlets()
scala.collection.immutable.IndexedSeq<Inlet<T>>	inSeq()
int	n()
protected static <T> Inlet<T>	newInlet(java.lang.String name)
static Outlet<O>	out()
static scala.collection.immutable.Seq<Outlet<?>>	outlets()
static void	requireSamePortsAndShapeAs(Shape s)
static void	requireSamePortsAs(Shape s)

Methods inherited from class akka.stream.FanInShape

copyFromPorts, inlets, newInlet, out, outlets

Methods inherited from class akka.stream.Shape

getInlets, getOutlets, hasSamePortsAndShapeAs, hasSamePortsAs, requireSamePortsAndShapeAs, requireSamePortsAs

Methods inherited from class java.lang.Object

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

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)

UniformFanInShape

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

Method Detail

apply

public static <I,O> UniformFanInShape<I,O> apply(Outlet<O> outlet,
                                                 scala.collection.Seq<Inlet<I>> inlets)

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)

out

public static final Outlet<O> out()

outlets

public static final scala.collection.immutable.Seq<Outlet<?>> outlets()

inlets

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

newInlet

protected static <T> Inlet<T> newInlet(java.lang.String name)

copyFromPorts

public static final FanInShape<O> copyFromPorts(scala.collection.immutable.Seq<Inlet<?>> inlets,
                                                scala.collection.immutable.Seq<Outlet<?>> outlets)

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>

Returns:

(undocumented)

inSeq

public scala.collection.immutable.IndexedSeq<Inlet<T>> inSeq()

in

public Inlet<T> in(int n)