akka.stream.scaladsl

Class GraphDSL.Builder<M>

java.lang.Object

akka.stream.scaladsl.GraphDSL.Builder<M>

Enclosing class:

GraphDSL

public static class GraphDSL.Builder<M>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
<S extends Shape> S	add(Graph<S,?> graph) Import a graph into this module, performing a deep copy, discarding its materialized value and returning the copied Ports that are now to be connected.
<S extends Shape,A> S	add(Graph<S,?> graph, scala.Function1<A,java.lang.Object> transform) INTERNAL API.
<S extends Shape,A,B> S	add(Graph<S,?> graph, scala.Function2<A,B,java.lang.Object> combine) INTERNAL API.
<T,U> void	addEdge(Outlet<T> from, Inlet<U> to) INTERNAL API
GraphDSL.Builder<M>	asJava() Converts this Scala DSL element to it's Java DSL counterpart.
Outlet<M>	materializedValue() Returns an Outlet that gives access to the materialized value of this graph.
StreamLayout.Module	module()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder()

Method Detail

addEdge

public <T,U> void addEdge(Outlet<T> from,
                          Inlet<U> to)

INTERNAL API

Parameters:

from - (undocumented)

to - (undocumented)

add

public <S extends Shape> S add(Graph<S,?> graph)

Import a graph into this module, performing a deep copy, discarding its materialized value and returning the copied Ports that are now to be connected.

Parameters:

graph - (undocumented)

Returns:

(undocumented)

add

public <S extends Shape,A> S add(Graph<S,?> graph,
                                 scala.Function1<A,java.lang.Object> transform)

INTERNAL API.

This is only used by the materialization-importing apply methods of Source, Flow, Sink and Graph.

Parameters:

graph - (undocumented)

transform - (undocumented)

Returns:

(undocumented)

add

public <S extends Shape,A,B> S add(Graph<S,?> graph,
                                   scala.Function2<A,B,java.lang.Object> combine)

INTERNAL API.

This is only used by the materialization-importing apply methods of Source, Flow, Sink and Graph.

Parameters:

graph - (undocumented)

combine - (undocumented)

Returns:

(undocumented)

materializedValue

public Outlet<M> materializedValue()

Returns an Outlet that gives access to the materialized value of this graph. Once the graph is materialized this outlet will emit exactly one element which is the materialized value. It is possible to expose this outlet as an externally accessible outlet of a Source, Sink, Flow or BidiFlow.

It is possible to call this method multiple times to get multiple Outlet instances if necessary. All of the outlets will emit the materialized value.

Be careful to not to feed the result of this outlet to a stage that produces the materialized value itself (for example to a Sink.fold(U, scala.Function2<U, T, U>) that contributes to the materialized value) since that might lead to an unresolvable dependency cycle.

Returns:

The outlet that will emit the materialized value.

module

public StreamLayout.Module module()

asJava

public GraphDSL.Builder<M> asJava()

Converts this Scala DSL element to it's Java DSL counterpart.