public abstract class RunnableGraph<Mat> extends java.lang.Object implements Graph<ClosedShape,Mat>
Flow with attached input and output, can be executed.
Constructor and Description |
---|
RunnableGraph() |
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) |
public static <Mat> RunnableGraph<Mat> fromGraph(Graph<ClosedShape,Mat> graph)
graph
- (undocumented)public abstract static S shape()
public abstract static StreamLayout.Module module()
public static Graph<S,M> async()
public abstract Mat run(Materializer materializer)
materializer
- (undocumented)public abstract <Mat2> RunnableGraph<Mat2> mapMaterializedValue(Function<Mat,Mat2> f)
f
- (undocumented)public abstract RunnableGraph<Mat> withAttributes(Attributes attr)
withAttributes
in interface Graph<ClosedShape,Mat>
public RunnableGraph<Mat> addAttributes(Attributes attr)
addAttributes
in interface Graph<ClosedShape,Mat>
public RunnableGraph<Mat> named(java.lang.String name)
named
in interface Graph<ClosedShape,Mat>