akka.stream.scaladsl

Class RunnableGraph<Mat>

java.lang.Object

akka.stream.scaladsl.RunnableGraph<Mat>

All Implemented Interfaces:

Graph<ClosedShape,Mat>, java.io.Serializable, scala.Equals, scala.Product

public final class RunnableGraph<Mat>
extends java.lang.Object
implements Graph<ClosedShape,Mat>, scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RunnableGraph(StreamLayout.Module module)

Method Summary

Modifier and Type	Method and Description
RunnableGraph<Mat>	addAttributes(Attributes attr)
RunnableGraph<Mat>	async() Put an asynchronous boundary around this Graph
abstract static boolean	canEqual(java.lang.Object that)
abstract static boolean	equals(java.lang.Object that)
static <Mat> RunnableGraph<Mat>	fromGraph(Graph<ClosedShape,Mat> g) A graph with a closed shape is logically a runnable graph, this method makes it so also in type.
<Mat2> RunnableGraph<Mat2>	mapMaterializedValue(scala.Function1<Mat,Mat2> f) Transform only the materialized value of this RunnableGraph, leaving all other properties as they were.
StreamLayout.Module	module() INTERNAL API.
RunnableGraph<Mat>	named(java.lang.String name)
abstract static int	productArity()
abstract static java.lang.Object	productElement(int n)
static scala.collection.Iterator<java.lang.Object>	productIterator()
static java.lang.String	productPrefix()
Mat	run(Materializer materializer) Run this flow and return the materialized instance from the flow.
ClosedShape$	shape() The shape of a graph is all that is externally visible: its inlets and outlets.
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 scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

RunnableGraph

public RunnableGraph(StreamLayout.Module module)

Method Detail

fromGraph

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

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

Parameters:

g - (undocumented)

Returns:

(undocumented)

canEqual

public abstract static boolean canEqual(java.lang.Object that)

equals

public abstract static boolean equals(java.lang.Object that)

productElement

public abstract static java.lang.Object productElement(int n)

productArity

public abstract static int productArity()

productIterator

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

productPrefix

public static java.lang.String productPrefix()

module

public StreamLayout.Module module()

Description copied from interface: Graph

INTERNAL API.

Every materializable element must be backed by a stream layout module

Specified by:

module in interface Graph<ClosedShape,Mat>

Returns:

(undocumented)

shape

public ClosedShape$ 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<ClosedShape,Mat>

Returns:

(undocumented)

mapMaterializedValue

public <Mat2> RunnableGraph<Mat2> mapMaterializedValue(scala.Function1<Mat,Mat2> f)

Transform only the materialized value of this RunnableGraph, leaving all other properties as they were.

Parameters:

f - (undocumented)

Returns:

(undocumented)

run

public Mat run(Materializer materializer)

Run this flow and return the materialized instance from the flow.

Parameters:

materializer - (undocumented)

Returns:

(undocumented)

addAttributes

public RunnableGraph<Mat> addAttributes(Attributes attr)

Specified by:

addAttributes in interface Graph<ClosedShape,Mat>

withAttributes

public RunnableGraph<Mat> withAttributes(Attributes attr)

Specified by:

withAttributes in interface Graph<ClosedShape,Mat>

named

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

Specified by:

named in interface Graph<ClosedShape,Mat>

async

public RunnableGraph<Mat> async()

Description copied from interface: Graph

Put an asynchronous boundary around this Graph

Specified by:

async in interface Graph<ClosedShape,Mat>

Returns:

(undocumented)