akka.stream.javadsl

Class Flow$

java.lang.Object

akka.stream.javadsl.Flow$

public class Flow$
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static Flow$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
Flow$()

Method Summary

Modifier and Type	Method and Description
<T> Flow<T,T,NotUsed>	create() Create a `Flow` which can process elements of type `T`.
<I,O> Flow<I,O,NotUsed>	fromFunction(Function<I,O> f) Creates a [Flow] which will use the given function to transform its inputs to outputs.
<I,O,M> Flow<I,O,M>	fromGraph(Graph<FlowShape<I,O>,M> g) A graph with the shape of a flow logically is a flow, this method makes it so also in type.
<I,O> Flow<I,O,NotUsed>	fromProcessor(Creator<org.reactivestreams.Processor<I,O>> processorFactory)
<I,O,Mat> Flow<I,O,Mat>	fromProcessorMat(Creator<Pair<org.reactivestreams.Processor<I,O>,Mat>> processorFactory)
<I,O> Flow<I,O,NotUsed>	fromSinkAndSource(Graph<SinkShape<I>,?> sink, Graph<SourceShape<O>,?> source) Helper to create Flow from a Sinkand a Source.
<I,O,M1,M2,M> Flow<I,O,M>	fromSinkAndSourceMat(Graph<SinkShape<I>,M1> sink, Graph<SourceShape<O>,M2> source, Function2<M1,M2,M> combine) Helper to create Flow from a Sinkand a Source.
<T> Flow<T,T,NotUsed>	of(java.lang.Class<T> clazz) Create a `Flow` which can process elements of type `T`.

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final Flow$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

Flow$

public Flow$()

Method Detail

create

public <T> Flow<T,T,NotUsed> create()

Create a `Flow` which can process elements of type `T`.

fromProcessor

public <I,O> Flow<I,O,NotUsed> fromProcessor(Creator<org.reactivestreams.Processor<I,O>> processorFactory)

fromProcessorMat

public <I,O,Mat> Flow<I,O,Mat> fromProcessorMat(Creator<Pair<org.reactivestreams.Processor<I,O>,Mat>> processorFactory)

fromFunction

public <I,O> Flow<I,O,NotUsed> fromFunction(Function<I,O> f)

Creates a [Flow] which will use the given function to transform its inputs to outputs. It is equivalent to Flow.create[T].map(f)

Parameters:

f - (undocumented)

Returns:

(undocumented)

of

public <T> Flow<T,T,NotUsed> of(java.lang.Class<T> clazz)

Create a `Flow` which can process elements of type `T`.

fromGraph

public <I,O,M> Flow<I,O,M> fromGraph(Graph<FlowShape<I,O>,M> g)

A graph with the shape of a flow logically is a flow, this method makes it so also in type.

Parameters:

g - (undocumented)

Returns:

(undocumented)

fromSinkAndSource

public <I,O> Flow<I,O,NotUsed> fromSinkAndSource(Graph<SinkShape<I>,?> sink,
                                                 Graph<SourceShape<O>,?> source)

Helper to create Flow from a Sinkand a Source.

Parameters:

sink - (undocumented)

source - (undocumented)

Returns:

(undocumented)

fromSinkAndSourceMat

public <I,O,M1,M2,M> Flow<I,O,M> fromSinkAndSourceMat(Graph<SinkShape<I>,M1> sink,
                                                      Graph<SourceShape<O>,M2> source,
                                                      Function2<M1,M2,M> combine)

Helper to create Flow from a Sinkand a Source.

Parameters:

sink - (undocumented)

source - (undocumented)

combine - (undocumented)

Returns:

(undocumented)