akka.stream.scaladsl

Class Flow$

java.lang.Object

akka.stream.scaladsl.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>	apply() Returns a Flow which outputs all its inputs.
<A,B> Flow<A,B,NotUsed>	fromFunction(scala.Function1<A,B> 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(scala.Function0<org.reactivestreams.Processor<I,O>> processorFactory) Creates a Flow from a Reactive Streams Processor
<I,O,M> Flow<I,O,M>	fromProcessorMat(scala.Function0<scala.Tuple2<org.reactivestreams.Processor<I,O>,M>> processorFactory) Creates a Flow from a Reactive Streams Processor and returns a materialized value.
<I,O> Flow<I,O,NotUsed>	fromSinkAndSource(Graph<SinkShape<I>,?> sink, Graph<SourceShape<O>,?> source) Creates a Flow from a Sink and a Source where the Flow's input will be sent to the Sink and the Flow's output will come from the Source.
<I,O,M1,M2,M> Flow<I,O,M>	fromSinkAndSourceMat(Graph<SinkShape<I>,M1> sink, Graph<SourceShape<O>,M2> source, scala.Function2<M1,M2,M> combine) Creates a Flow from a Sink and a Source where the Flow's input will be sent to the Sink and the Flow's output will come from the Source.

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

fromProcessor

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

Creates a Flow from a Reactive Streams Processor

Parameters:

processorFactory - (undocumented)

Returns:

(undocumented)

fromProcessorMat

public <I,O,M> Flow<I,O,M> fromProcessorMat(scala.Function0<scala.Tuple2<org.reactivestreams.Processor<I,O>,M>> processorFactory)

Creates a Flow from a Reactive Streams Processor and returns a materialized value.

Parameters:

processorFactory - (undocumented)

Returns:

(undocumented)

apply

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

Returns a Flow which outputs all its inputs.

Returns:

(undocumented)

fromFunction

public <A,B> Flow<A,B,NotUsed> fromFunction(scala.Function1<A,B> f)

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

Parameters:

f - (undocumented)

Returns:

(undocumented)

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)

Creates a Flow from a Sink and a Source where the Flow's input will be sent to the Sink and the Flow's output will come from the 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,
                                                      scala.Function2<M1,M2,M> combine)

Creates a Flow from a Sink and a Source where the Flow's input will be sent to the Sink and the Flow's output will come from the Source.

The combine function is used to compose the materialized values of the sink and source into the materialized value of the resulting Flow.

Parameters:

sink - (undocumented)

source - (undocumented)

combine - (undocumented)

Returns:

(undocumented)