Package akka.stream.impl

Class TraversalBuilder$

java.lang.Object

akka.stream.impl.TraversalBuilder$

public class TraversalBuilder$
extends java.lang.Object

INTERNAL API

Assign 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

Modifier and Type	Method	Description
TraversalBuilder	atomic(StreamLayout.AtomicModule<Shape,java.lang.Object> module, Attributes attributes)	INTERNAL API
TraversalBuilder	empty(Attributes attributes)	INTERNAL API
Attributes	empty$default$1()
<A> OptionVal<GraphStages.SingleSource<A>>	getSingleSource(Graph<SourceShape<A>,?> graph)	Try to find SingleSource or wrapped such.
void	initShape(Shape shape)	INTERNAL API
void	printTraversal(Traversal t, int indent)	INTERNAL API
int	printTraversal$default$2()
int	printWiring(Traversal t, int baseSlot)	INTERNAL API
int	printWiring$default$2()

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final TraversalBuilder$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

TraversalBuilder$

public TraversalBuilder$()

Method Detail

initShape

public void initShape(Shape shape)

INTERNAL API

Assign 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 API

Create 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 find SingleSource or wrapped such. This is used as a performance optimization in FlattenMerge and possibly other places.

Parameters:

graph - (undocumented)

Returns:

(undocumented)