Package akka.stream.impl.fusing

Class GraphStageModule<S extends Shape,M>

java.lang.Object

akka.stream.impl.fusing.GraphStageModule<S,M>

All Implemented Interfaces:

Graph<S,M>, StreamLayout.AtomicModule<S,M>, java.io.Serializable, scala.Equals, scala.Product, scala.Serializable

public final class GraphStageModule<S extends Shape,M>
extends java.lang.Object
implements StreamLayout.AtomicModule<S,M>, scala.Product, scala.Serializable

INTERNAL API

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
GraphStageModule(S shape, Attributes attributes, GraphStageWithMaterializedValue<S,M> stage)

Method Summary

Modifier and Type	Method	Description
static <S extends Shape,M> GraphStageModule<S,M>	apply(S shape, Attributes attributes, GraphStageWithMaterializedValue<S,M> stage)
Attributes	attributes()
boolean	canEqual(java.lang.Object x$1)
<S extends <any>,M> GraphStageModule<S,M>	copy(S shape, Attributes attributes, GraphStageWithMaterializedValue<S,M> stage)
<S extends <any>,M> S	copy$default$1()
<S extends <any>,M> Attributes	copy$default$2()
<S extends <any>,M> GraphStageWithMaterializedValue<S,M>	copy$default$3()
boolean	equals(java.lang.Object x$1)
int	hashCode()
int	productArity()
java.lang.Object	productElement(int x$1)
scala.collection.Iterator<java.lang.Object>	productIterator()
java.lang.String	productPrefix()
S	shape()	The shape of a graph is all that is externally visible: its inlets and outlets.
GraphStageWithMaterializedValue<S,M>	stage()
java.lang.String	toString()
LinearTraversalBuilder	traversalBuilder()	INTERNAL API.
static <S extends Shape,M> scala.Option<scala.Tuple3<S,Attributes,GraphStageWithMaterializedValue<S,M>>>	unapply(GraphStageModule<S,M> x$0)
StreamLayout.AtomicModule<S,M>	withAttributes(Attributes attributes)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface akka.stream.Graph

addAttributes, async, async, async, named

Constructor Detail

GraphStageModule

public GraphStageModule(S shape,
                        Attributes attributes,
                        GraphStageWithMaterializedValue<S,M> stage)

Method Detail

apply

public static <S extends Shape,M> GraphStageModule<S,M> apply(S shape,
                                                                          Attributes attributes,
                                                                          GraphStageWithMaterializedValue<S,M> stage)

unapply

public static <S extends Shape,M> scala.Option<scala.Tuple3<S,Attributes,GraphStageWithMaterializedValue<S,M>>> unapply(GraphStageModule<S,M> x$0)

shape

public S shape()

Description copied from interface: Graph

The shape of a graph is all that is externally visible: its inlets and outlets.

Specified by:

shape in interface Graph<S extends Shape,M>

Returns:

(undocumented)

attributes

public Attributes attributes()

stage

public GraphStageWithMaterializedValue<S,M> stage()

withAttributes

public StreamLayout.AtomicModule<S,M> withAttributes(Attributes attributes)

Specified by:

withAttributes in interface Graph<S extends Shape,M>

traversalBuilder

public LinearTraversalBuilder traversalBuilder()

Description copied from interface: Graph

INTERNAL API.

Every materializable element must be backed by a stream layout module

Specified by:

traversalBuilder in interface Graph<S extends Shape,M>

Returns:

(undocumented)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

copy

public <S extends <any>,M> GraphStageModule<S,M> copy(S shape,
                                                                  Attributes attributes,
                                                                  GraphStageWithMaterializedValue<S,M> stage)

copy$default$1

public <S extends <any>,M> S copy$default$1()

copy$default$2

public <S extends <any>,M> Attributes copy$default$2()

copy$default$3

public <S extends <any>,M> GraphStageWithMaterializedValue<S,M> copy$default$3()

productPrefix

public java.lang.String productPrefix()

Specified by:

productPrefix in interface scala.Product

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

public java.lang.Object productElement(int x$1)

Specified by:

productElement in interface scala.Product

productIterator

public scala.collection.Iterator<java.lang.Object> productIterator()

Specified by:

productIterator in interface scala.Product

canEqual

public boolean canEqual(java.lang.Object x$1)

Specified by:

canEqual in interface scala.Equals

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object x$1)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class java.lang.Object