akka.stream.impl

Class StreamLayout.CompositeModule

java.lang.Object

akka.stream.impl.StreamLayout.CompositeModule

All Implemented Interfaces:

StreamLayout.Module, java.io.Serializable, scala.Equals, scala.Product

Enclosing class:

StreamLayout

public static final class StreamLayout.CompositeModule
extends java.lang.Object
implements StreamLayout.Module, scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CompositeModule(scala.collection.immutable.Set<StreamLayout.Module> subModules, Shape shape, scala.collection.immutable.Map<OutPort,InPort> downstreams, scala.collection.immutable.Map<InPort,OutPort> upstreams, StreamLayout.MaterializedValueNode materializedValueComputation, Attributes attributes)

Method Summary

Modifier and Type	Method and Description
Attributes	attributes()
StreamLayout.Module	carbonCopy() The purpose of this method is to create a copy to be included in a larger graph such that port identity clashes are avoided.
scala.collection.immutable.Map<OutPort,InPort>	downstreams()
scala.collection.immutable.Set<InPort>	inPorts()
StreamLayout.MaterializedValueNode	materializedValueComputation()
scala.collection.immutable.Set<OutPort>	outPorts()
StreamLayout.Module	replaceShape(Shape s) Verify that the given Shape has the same ports and return a new module with that shape.
Shape	shape()
scala.collection.immutable.Set<StreamLayout.Module>	subModules()
java.lang.String	toString()
scala.collection.immutable.Map<InPort,OutPort>	upstreams()
StreamLayout.Module	withAttributes(Attributes attributes)

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.stream.impl.StreamLayout.Module

compose, compose, composeNoMat, equals, fuse, fuse, hashCode, isAtomic, isBidiFlow, isCopied, isFlow, isFused, isRunnable, isSealed, isSink, isSource, transformMaterializedValue, wire

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

CompositeModule

public CompositeModule(scala.collection.immutable.Set<StreamLayout.Module> subModules,
                       Shape shape,
                       scala.collection.immutable.Map<OutPort,InPort> downstreams,
                       scala.collection.immutable.Map<InPort,OutPort> upstreams,
                       StreamLayout.MaterializedValueNode materializedValueComputation,
                       Attributes attributes)

Method Detail

inPorts

public final scala.collection.immutable.Set<InPort> inPorts()

Specified by:

inPorts in interface StreamLayout.Module

outPorts

public final scala.collection.immutable.Set<OutPort> outPorts()

Specified by:

outPorts in interface StreamLayout.Module

subModules

public scala.collection.immutable.Set<StreamLayout.Module> subModules()

Specified by:

subModules in interface StreamLayout.Module

shape

public Shape shape()

Specified by:

shape in interface StreamLayout.Module

downstreams

public scala.collection.immutable.Map<OutPort,InPort> downstreams()

Specified by:

downstreams in interface StreamLayout.Module

upstreams

public scala.collection.immutable.Map<InPort,OutPort> upstreams()

Specified by:

upstreams in interface StreamLayout.Module

materializedValueComputation

public StreamLayout.MaterializedValueNode materializedValueComputation()

Specified by:

materializedValueComputation in interface StreamLayout.Module

attributes

public Attributes attributes()

Specified by:

attributes in interface StreamLayout.Module

replaceShape

public StreamLayout.Module replaceShape(Shape s)

Description copied from interface: StreamLayout.Module

Verify that the given Shape has the same ports and return a new module with that shape. Concrete implementations may throw UnsupportedOperationException where applicable.

Please note that this method MUST NOT be implemented using a CopiedModule since the purpose of replaceShape can also be to rearrange the ports (as in BidiFlow.reversed) and that purpose would be defeated.

Specified by:

replaceShape in interface StreamLayout.Module

Parameters:

s - (undocumented)

Returns:

(undocumented)

carbonCopy

public StreamLayout.Module carbonCopy()

Description copied from interface: StreamLayout.Module

The purpose of this method is to create a copy to be included in a larger graph such that port identity clashes are avoided. Where a full copy is not possible or desirable, use a CopiedModule. The shape of the resulting module MUST NOT contain the same ports as this module’s shape.

Specified by:

carbonCopy in interface StreamLayout.Module

Returns:

(undocumented)

withAttributes

public StreamLayout.Module withAttributes(Attributes attributes)

Specified by:

withAttributes in interface StreamLayout.Module

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object