Package akka.stream.impl
Class TraversalBuilder$
- java.lang.Object
-
- akka.stream.impl.TraversalBuilder$
-
public class TraversalBuilder$ extends java.lang.Object
INTERNAL APIAssign ports their id, which is their position inside the Shape. This is used both by the GraphInterpreter and the layout system here.
-
-
Field Summary
Fields Modifier and Type Field Description static TraversalBuilder$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description TraversalBuilder$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description TraversalBuilder
atomic(StreamLayout.AtomicModule<Shape,java.lang.Object> module, Attributes attributes)
INTERNAL APITraversalBuilder
empty(Attributes attributes)
INTERNAL APIAttributes
empty$default$1()
<A> OptionVal<GraphStages.SingleSource<A>>
getSingleSource(Graph<SourceShape<A>,?> graph)
Try to findSingleSource
or wrapped such.void
initShape(Shape shape)
INTERNAL APIvoid
printTraversal(Traversal t, int indent)
INTERNAL APIint
printTraversal$default$2()
int
printWiring(Traversal t, int baseSlot)
INTERNAL APIint
printWiring$default$2()
-
-
-
Field Detail
-
MODULE$
public static final TraversalBuilder$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
initShape
public void initShape(Shape shape)
INTERNAL APIAssign ports their id, which is their position inside the Shape. This is used both by the GraphInterpreter and the layout system here.
- Parameters:
shape
- (undocumented)
-
empty
public TraversalBuilder empty(Attributes attributes)
INTERNAL API- Parameters:
attributes
- (undocumented)- Returns:
- (undocumented)
-
empty$default$1
public Attributes empty$default$1()
-
atomic
public TraversalBuilder atomic(StreamLayout.AtomicModule<Shape,java.lang.Object> module, Attributes attributes)
INTERNAL APICreate a generic traversal builder starting from an atomic module.
- Parameters:
module
- (undocumented)attributes
- (undocumented)- Returns:
- (undocumented)
-
printTraversal
public void printTraversal(Traversal t, int indent)
INTERNAL API- Parameters:
t
- (undocumented)indent
- (undocumented)
-
printTraversal$default$2
public int printTraversal$default$2()
-
printWiring
public int printWiring(Traversal t, int baseSlot)
INTERNAL API- Parameters:
t
- (undocumented)baseSlot
- (undocumented)- Returns:
- (undocumented)
-
printWiring$default$2
public int printWiring$default$2()
-
getSingleSource
public <A> OptionVal<GraphStages.SingleSource<A>> getSingleSource(Graph<SourceShape<A>,?> graph)
Try to findSingleSource
or wrapped such. This is used as a performance optimization in FlattenMerge and possibly other places.- Parameters:
graph
- (undocumented)- Returns:
- (undocumented)
-
-