akka.stream

Class UniformFanOutShape<I,O>

java.lang.Object

akka.stream.Shape

akka.stream.FanOutShape<I>

akka.stream.UniformFanOutShape<I,O>

public class UniformFanOutShape<I,O>
extends FanOutShape<I>

Nested Class Summary

Nested classes/interfaces inherited from class akka.stream.FanOutShape

FanOutShape.Init<I>, FanOutShape.Name<I>, FanOutShape.Name$, FanOutShape.Ports<I>, FanOutShape.Ports$

Constructor Summary

Constructors

Constructor and Description
UniformFanOutShape(Inlet<I> inlet, Outlet<O>[] outlets)
UniformFanOutShape(int n)
UniformFanOutShape(int n, FanOutShape.Init<I> _init)
UniformFanOutShape(int n, java.lang.String name)

Method Summary

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

Methods inherited from class akka.stream.FanOutShape

copyFromPorts, in, inlets, newOutlet, 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

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

apply

public static <I,O> UniformFanOutShape<I,O> apply(Inlet<I> inlet,
                                                  scala.collection.Seq<Outlet<O>> outlets)

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()

outlets

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

inlets

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

newOutlet

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

copyFromPorts

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

construct

protected FanOutShape<I> construct(FanOutShape.Init<I> init)

Specified by:

construct in class FanOutShape<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 class FanOutShape<I>

Returns:

(undocumented)

outArray

public Outlet<O>[] outArray()

out

public Outlet<O> out(int n)