Package org.apache.pekko.stream.javadsl

Class GraphDSL.Builder<Mat>

java.lang.Object

org.apache.pekko.stream.javadsl.GraphDSL.Builder<Mat>

Enclosing class:

GraphDSL

public static final class GraphDSL.Builder<Mat>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	GraphDSL.Builder.ForwardOps<T>
final class	GraphDSL.Builder.ReverseOps<T>

Constructor Summary

Constructors

Constructor	Description
Builder(org.apache.pekko.stream.scaladsl.GraphDSL.Builder<Mat> delegate)

Method Summary

Modifier and Type	Method	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.
<I, O> GraphDSL.Builder<Mat>.ForwardOps<O>	from(FlowShape<I,O> f)
<T> GraphDSL.Builder<Mat>.ForwardOps<T>	from(Outlet<T> out)
<T> GraphDSL.Builder<Mat>.ForwardOps<T>	from(SourceShape<T> src)
<I, O> GraphDSL.Builder<Mat>.ForwardOps<O>	from(UniformFanInShape<I,O> j)
<I, O> GraphDSL.Builder<Mat>.ForwardOps<O>	from(UniformFanOutShape<I,O> j)
Outlet<Mat>	materializedValue()	Returns an Outlet that gives access to the materialized value of this graph.
<I, O> GraphDSL.Builder<Mat>.ReverseOps<I>	to(FlowShape<I,O> f)
<T> GraphDSL.Builder<Mat>.ReverseOps<T>	to(Inlet<T> in)
<T> GraphDSL.Builder<Mat>.ReverseOps<T>	to(SinkShape<T> dst)
<I, O> GraphDSL.Builder<Mat>.ReverseOps<I>	to(UniformFanInShape<I,O> j)
<I, O> GraphDSL.Builder<Mat>.ReverseOps<I>	to(UniformFanOutShape<I,O> j)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder(org.apache.pekko.stream.scaladsl.GraphDSL.Builder<Mat> delegate)

Method Details

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.

from

public <T> GraphDSL.Builder<Mat>.ForwardOps<T> from(Outlet<T> out)

from

public <T> GraphDSL.Builder<Mat>.ForwardOps<T> from(SourceShape<T> src)

from

public <I,
O> GraphDSL.Builder<Mat>.ForwardOps<O> from(FlowShape<I,O> f)

from

public <I,
O> GraphDSL.Builder<Mat>.ForwardOps<O> from(UniformFanInShape<I,O> j)

from

public <I,
O> GraphDSL.Builder<Mat>.ForwardOps<O> from(UniformFanOutShape<I,O> j)

materializedValue

public Outlet<Mat> 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 operator that produces the materialized value itself (for example to a Sink.fold(U, org.apache.pekko.japi.function.Function2<U, In, 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.

to

public <T> GraphDSL.Builder<Mat>.ReverseOps<T> to(Inlet<T> in)

to

public <T> GraphDSL.Builder<Mat>.ReverseOps<T> to(SinkShape<T> dst)

to

public <I,
O> GraphDSL.Builder<Mat>.ReverseOps<I> to(FlowShape<I,O> f)

to

public <I,
O> GraphDSL.Builder<Mat>.ReverseOps<I> to(UniformFanInShape<I,O> j)

to

public <I,
O> GraphDSL.Builder<Mat>.ReverseOps<I> to(UniformFanOutShape<I,O> j)