public static class StreamLayout.EmptyModule$ extends java.lang.Object implements StreamLayout.Module, scala.Product, scala.Serializable
Modifier and Type | Field and Description |
---|---|
static StreamLayout.EmptyModule$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
EmptyModule$() |
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 |
compose(StreamLayout.Module that)
Creates a new Module which is
this Module composed with that Module. |
<A,B,C> StreamLayout.Module |
compose(StreamLayout.Module that,
scala.Function2<A,B,C> f)
Creates a new Module which is
this Module composed with that Module,
using the given function f to compose the materialized value of this with
the materialized value of that . |
scala.collection.immutable.Set<InPort> |
inPorts() |
boolean |
isAtomic() |
boolean |
isRunnable() |
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.
|
ClosedShape$ |
shape() |
scala.collection.immutable.Set<StreamLayout.Module> |
subModules() |
StreamLayout.Module |
withAttributes(Attributes attributes) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
composeNoMat, downstreams, equals, fuse, fuse, hashCode, isBidiFlow, isCopied, isFlow, isFused, isSealed, isSink, isSource, transformMaterializedValue, upstreams, wire
public static final StreamLayout.EmptyModule$ MODULE$
public final scala.collection.immutable.Set<InPort> inPorts()
inPorts
in interface StreamLayout.Module
public final scala.collection.immutable.Set<OutPort> outPorts()
outPorts
in interface StreamLayout.Module
public ClosedShape$ shape()
shape
in interface StreamLayout.Module
public StreamLayout.Module replaceShape(Shape s)
StreamLayout.Module
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.
replaceShape
in interface StreamLayout.Module
s
- (undocumented)public StreamLayout.Module compose(StreamLayout.Module that)
StreamLayout.Module
this
Module composed with that
Module.
compose
in interface StreamLayout.Module
that
- a Module to be composed with (cannot be itself)this
and that
public <A,B,C> StreamLayout.Module compose(StreamLayout.Module that, scala.Function2<A,B,C> f)
StreamLayout.Module
this
Module composed with that
Module,
using the given function f
to compose the materialized value of this
with
the materialized value of that
.
compose
in interface StreamLayout.Module
that
- a Module to be composed with (cannot be itself)f
- a function which combines the materialized valuesthis
and that
public StreamLayout.Module withAttributes(Attributes attributes)
withAttributes
in interface StreamLayout.Module
public scala.collection.immutable.Set<StreamLayout.Module> subModules()
subModules
in interface StreamLayout.Module
public Attributes attributes()
attributes
in interface StreamLayout.Module
public StreamLayout.Module carbonCopy()
StreamLayout.Module
carbonCopy
in interface StreamLayout.Module
public boolean isRunnable()
isRunnable
in interface StreamLayout.Module
public boolean isAtomic()
isAtomic
in interface StreamLayout.Module
public StreamLayout.MaterializedValueNode materializedValueComputation()
materializedValueComputation
in interface StreamLayout.Module