public final class RunnableGraph<Mat> extends java.lang.Object implements Graph<ClosedShape,Mat>, scala.Product, scala.Serializable
Constructor and Description |
---|
RunnableGraph(StreamLayout.Module module) |
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public RunnableGraph(StreamLayout.Module module)
public static <Mat> RunnableGraph<Mat> fromGraph(Graph<ClosedShape,Mat> g)
g
- (undocumented)public abstract static boolean canEqual(java.lang.Object that)
public abstract static boolean equals(java.lang.Object that)
public abstract static java.lang.Object productElement(int n)
public abstract static int productArity()
public static scala.collection.Iterator<java.lang.Object> productIterator()
public static java.lang.String productPrefix()
public StreamLayout.Module module()
Graph
Every materializable element must be backed by a stream layout module
module
in interface Graph<ClosedShape,Mat>
public ClosedShape$ shape()
Graph
shape
in interface Graph<ClosedShape,Mat>
public <Mat2> RunnableGraph<Mat2> mapMaterializedValue(scala.Function1<Mat,Mat2> f)
f
- (undocumented)public Mat run(Materializer materializer)
materializer
- (undocumented)public RunnableGraph<Mat> addAttributes(Attributes attr)
addAttributes
in interface Graph<ClosedShape,Mat>
public RunnableGraph<Mat> withAttributes(Attributes attr)
withAttributes
in interface Graph<ClosedShape,Mat>
public RunnableGraph<Mat> named(java.lang.String name)
named
in interface Graph<ClosedShape,Mat>
public RunnableGraph<Mat> async()
Graph
Graph
async
in interface Graph<ClosedShape,Mat>