akka.stream.impl

Class StreamLayout.CopiedModule

java.lang.Object

akka.stream.impl.StreamLayout.CopiedModule

All Implemented Interfaces:

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

Enclosing class:

StreamLayout

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CopiedModule(Shape shape, Attributes attributes, StreamLayout.Module copyOf)

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.
StreamLayout.Module	copyOf()
scala.collection.immutable.Set<InPort>	inPorts()
boolean	isCopied()
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()
StreamLayout.Module	withAttributes(Attributes attr)

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, downstreams, equals, fuse, fuse, hashCode, isAtomic, isBidiFlow, isFlow, isFused, isRunnable, isSealed, isSink, isSource, transformMaterializedValue, upstreams, wire

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

CopiedModule

public CopiedModule(Shape shape,
                    Attributes attributes,
                    StreamLayout.Module copyOf)

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

shape

public Shape shape()

Specified by:

shape in interface StreamLayout.Module

attributes

public Attributes attributes()

Specified by:

attributes in interface StreamLayout.Module

copyOf

public StreamLayout.Module copyOf()

subModules

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

Specified by:

subModules in interface StreamLayout.Module

withAttributes

public StreamLayout.Module withAttributes(Attributes attr)

Specified by:

withAttributes in interface StreamLayout.Module

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)

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)

materializedValueComputation

public StreamLayout.MaterializedValueNode materializedValueComputation()

Specified by:

materializedValueComputation in interface StreamLayout.Module

isCopied

public boolean isCopied()

Specified by:

isCopied in interface StreamLayout.Module

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object