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.

Constructor Summary

Constructors

Constructor and Description
RunnableGraph()

Method Summary

Modifier and Type	Method and Description
RunnableGraph<Mat>	addAttributes(Attributes attr)
static Graph<S,M>	async()
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.
abstract static StreamLayout.Module	module()
RunnableGraph<Mat>	named(java.lang.String name)
abstract Mat	run(Materializer materializer) Run this flow and return the materialized values of the flow.
abstract static S	shape()
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, module, shape

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.

Parameters:

graph - (undocumented)

Returns:

(undocumented)

shape

public abstract static S shape()

module

public abstract static StreamLayout.Module module()

async

public static Graph<S,M> async()

run

public abstract Mat run(Materializer materializer)

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

Parameters:

materializer - (undocumented)

Returns:

(undocumented)

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)

Specified by:

addAttributes in interface Graph<ClosedShape,Mat>

named

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

Specified by:

named in interface Graph<ClosedShape,Mat>