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>

Java API

Flow with attached input and output, can be executed.

Nested Class Summary

Nested classes/interfaces inherited from interface akka.stream.Graph

Graph.GraphMapMatVal<S extends Shape,M>

Constructor Summary

Constructors

Constructor	Description
RunnableGraph()

Method Summary

Modifier and Type	Method	Description
RunnableGraph<Mat>	addAttributes(Attributes attr)	Add the given attributes to this Graph.
abstract RunnableGraph<Mat>	asScala()	Converts this Java DSL element to its Scala DSL counterpart.
static <Mat> RunnableGraph<Mat>	fromGraph(Graph<ClosedShape,Mat> graph)	A graph with a closed shape is logically a runnable graph, this method makes it so also in type.
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)	Specifies the name of the Graph.
Mat	run(ClassicActorSystemProvider systemProvider)	Run this flow and return the materialized values of the flow.
abstract Mat	run(Materializer materializer)	Run this flow using a special materializer and return the materialized values of the flow.
abstract RunnableGraph<Mat>	withAttributes(Attributes attr)	Replace the attributes of this Flow with the given ones.

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.stream.Graph

async, async, async, getAttributes, shape, traversalBuilder

Constructor Detail

RunnableGraph

public RunnableGraph()

Method Detail

fromGraph

public static <Mat> RunnableGraph<Mat> fromGraph(Graph<ClosedShape,Mat> graph)

A graph with a closed shape is logically a runnable graph, this method makes it so also in type.

run

public Mat run(ClassicActorSystemProvider systemProvider)

Run this flow and return the materialized values of the flow.

Uses the system materializer.

run

public abstract Mat run(Materializer materializer)

Run this flow using a special materializer and return the materialized values of the flow.

Prefer the method taking an ActorSystem unless you have special requirements.

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.

withAttributes

public abstract RunnableGraph<Mat> withAttributes(Attributes attr)

Description copied from interface: Graph

Replace the attributes of this Flow with the given ones. If this Flow 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:

withAttributes in interface Graph<ClosedShape,Mat>

addAttributes

public RunnableGraph<Mat> addAttributes(Attributes attr)

Description copied from interface: Graph

Add the given attributes to this Graph. 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 interface Graph<ClosedShape,Mat>

named

public RunnableGraph<Mat> named(java.lang.String name)

Description copied from interface: Graph

Specifies the name of the Graph. If the name is null or empty the name is ignored, i.e. #none is returned.

Specified by:

named in interface Graph<ClosedShape,Mat>

asScala

public abstract RunnableGraph<Mat> asScala()

Converts this Java DSL element to its Scala DSL counterpart.