Package org.apache.pekko.stream

Class FanInShape<O>

java.lang.Object

org.apache.pekko.stream.Shape

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

Direct Known Subclasses:

FanInShape10, FanInShape11, FanInShape12, FanInShape13, FanInShape14, FanInShape15, FanInShape16, FanInShape17, FanInShape18, FanInShape19, FanInShape2, FanInShape20, FanInShape21, FanInShape22, FanInShape3, FanInShape4, FanInShape5, FanInShape6, FanInShape7, FanInShape8, FanInShape9, UniformFanInShape

public abstract class FanInShape<O>
extends Shape

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	FanInShape.Init<O>
static final class	FanInShape.Name<O>
static class	FanInShape.Name$
static final class	FanInShape.Ports<O>
static class	FanInShape.Ports$

Constructor Summary

Constructors

Constructor	Description
FanInShape(FanInShape.Init<O> init)

Method Summary

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

FanInShape

public FanInShape(FanInShape.Init<O> init)

Method Details

out

public final Outlet<O> out()

outlets

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

inlets

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

Not meant for overriding outside of Apache Pekko.

Specified by:

inlets in class Shape

newInlet

protected <T> Inlet<T> newInlet(String name)

construct

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

deepCopy

public FanInShape<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.

Specified by:

deepCopy in class Shape