Package akka.stream.javadsl
Class RunnableGraph<Mat>
- java.lang.Object
-
- akka.stream.javadsl.RunnableGraph<Mat>
-
- All Implemented Interfaces:
Graph<ClosedShape,Mat>
public abstract class RunnableGraph<Mat> extends java.lang.Object implements Graph<ClosedShape,Mat>
Run this flow and return the materialized values of the flow.
-
-
Constructor Summary
Constructors Constructor Description RunnableGraph()
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description RunnableGraph<Mat>
addAttributes(Attributes attr)
Add the given attributes to thisGraph
.abstract RunnableGraph<Mat>
asScala()
Converts this Java DSL element to its Scala DSL counterpart.static <Mat> RunnableGraph<Mat>
fromGraph(Graph<ClosedShape,Mat> graph)
abstract <Mat2> RunnableGraph<Mat2>
mapMaterializedValue(Function<Mat,Mat2> f)
Transform only the materialized value of this RunnableGraph, leaving all other properties as they were.RunnableGraph<Mat>
named(java.lang.String name)
abstract Mat
run(Materializer materializer)
abstract RunnableGraph<Mat>
withAttributes(Attributes attr)
-
-
-
Method Detail
-
fromGraph
public static <Mat> RunnableGraph<Mat> fromGraph(Graph<ClosedShape,Mat> graph)
-
run
public abstract Mat run(Materializer materializer)
-
mapMaterializedValue
public abstract <Mat2> RunnableGraph<Mat2> mapMaterializedValue(Function<Mat,Mat2> f)
Transform only the materialized value of this RunnableGraph, leaving all other properties as they were.- Parameters:
f
- (undocumented)- Returns:
- (undocumented)
-
withAttributes
public abstract RunnableGraph<Mat> withAttributes(Attributes attr)
- Specified by:
withAttributes
in interfaceGraph<ClosedShape,Mat>
-
addAttributes
public RunnableGraph<Mat> addAttributes(Attributes attr)
Description copied from interface:Graph
Add the given attributes to thisGraph
. If the specific attribute was already present on this graph this means the added attribute will be more specific than the existing one. If this Source is a composite of multiple graphs, new attributes on the composite will be less specific than attributes set directly on the individual graphs of the composite.- Specified by:
addAttributes
in interfaceGraph<ClosedShape,Mat>
- Parameters:
attr
- (undocumented)- Returns:
- (undocumented)
-
named
public RunnableGraph<Mat> named(java.lang.String name)
- Specified by:
named
in interfaceGraph<ClosedShape,Mat>
-
asScala
public abstract RunnableGraph<Mat> asScala()
Converts this Java DSL element to its Scala DSL counterpart.- Returns:
- (undocumented)
-
-