akka.stream

Class FanOutShape<I>

java.lang.Object

akka.stream.Shape

akka.stream.FanOutShape<I>

Direct Known Subclasses:

FanOutShape10, FanOutShape11, FanOutShape12, FanOutShape13, FanOutShape14, FanOutShape15, FanOutShape16, FanOutShape17, FanOutShape18, FanOutShape19, FanOutShape2, FanOutShape20, FanOutShape21, FanOutShape22, FanOutShape3, FanOutShape4, FanOutShape5, FanOutShape6, FanOutShape7, FanOutShape8, FanOutShape9, UniformFanOutShape

public abstract class FanOutShape<I>
extends Shape

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	FanOutShape.Init<I>
static class	FanOutShape.Name<I>
static class	FanOutShape.Name$
static class	FanOutShape.Ports<I>
static class	FanOutShape.Ports$

Constructor Summary

Constructors

Constructor and Description
FanOutShape(FanOutShape.Init<I> init)

Method Summary

Modifier and Type	Method and Description
protected abstract FanOutShape<I>	construct(FanOutShape.Init<I> init)
FanOutShape<I>	copyFromPorts(scala.collection.immutable.Seq<Inlet<?>> inlets, scala.collection.immutable.Seq<Outlet<?>> outlets) Create a copy of this Shape object, returning the same type as the original but containing the ports given within the passed-in Shape.
FanOutShape<I>	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<I>	in()
scala.collection.immutable.Seq<Inlet<?>>	inlets() Scala API: get a list of all input ports
protected <T> Outlet<T>	newOutlet(java.lang.String name)
scala.collection.immutable.Seq<Outlet<?>>	outlets() Scala API: get a list of all output ports
static void	requireSamePortsAndShapeAs(Shape s)
static void	requireSamePortsAs(Shape s)

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

FanOutShape

public FanOutShape(FanOutShape.Init<I> init)

Method Detail

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 final Inlet<I> in()

outlets

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

Description copied from class: Shape

Scala API: get a list of all output ports

Specified by:

outlets in class Shape

Returns:

(undocumented)

inlets

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

Description copied from class: Shape

Scala API: get a list of all input ports

Specified by:

inlets in class Shape

Returns:

(undocumented)

newOutlet

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

construct

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

deepCopy

public FanOutShape<I> 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.

Specified by:

deepCopy in class Shape

Returns:

(undocumented)

copyFromPorts

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

Description copied from class: Shape

Create a copy of this Shape object, returning the same type as the original but containing the ports given within the passed-in Shape.

Specified by:

copyFromPorts in class Shape

Parameters:

inlets - (undocumented)

outlets - (undocumented)

Returns:

(undocumented)