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

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)
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)

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, shape, traversalBuilder

Constructor Detail

RunnableGraph

public RunnableGraph()

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

Parameters:

attr - (undocumented)

Returns:

(undocumented)

named

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

Specified by:

named in interface Graph<ClosedShape,Mat>

asScala

public abstract RunnableGraph<Mat> asScala()

Converts this Java DSL element to its Scala DSL counterpart.

Returns:

(undocumented)