Package org.apache.pekko.stream

Class FanOutShape<I>

java.lang.Object

org.apache.pekko.stream.Shape

org.apache.pekko.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	Description
static interface	FanOutShape.Init<I>
static final class	FanOutShape.Name<I>
static class	FanOutShape.Name$
static final class	FanOutShape.Ports<I>
static class	FanOutShape.Ports$

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected abstract FanOutShape<I>	construct(FanOutShape.Init<I> init)
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.
final Inlet<I>	in()
final scala.collection.immutable.Seq<Inlet<I>>	inlets()
protected <T> Outlet<T>	newOutlet(String name)
scala.collection.immutable.Seq<Outlet<?>>	outlets()	Not meant for overriding outside of Apache Pekko.

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

FanOutShape

public FanOutShape(FanOutShape.Init<I> init)

Method Details

in

public final Inlet<I> in()

outlets

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

Not meant for overriding outside of Apache Pekko.

Specified by:

outlets in class Shape

inlets

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

newOutlet

protected <T> Outlet<T> newOutlet(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