play.libs.streams

Class AkkaStreams

java.lang.Object

play.libs.streams.AkkaStreams

public class AkkaStreams
extends java.lang.Object

Akka streams utilities.

Constructor Summary

Constructors

Constructor and Description
AkkaStreams()

Method Summary

Modifier and Type	Method and Description
static <In,FlowIn,Out> akka.stream.javadsl.Flow<In,Out,?>	bypassWith(akka.stream.javadsl.Flow<In,F.Either<FlowIn,Out>,?> splitter, akka.stream.Graph<akka.stream.UniformFanInShape<Out,Out>,?> mergeStrategy, akka.stream.javadsl.Flow<FlowIn,Out,?> flow) Using the given splitter flow, allow messages to bypass a flow.
static <In,FlowIn,Out> akka.stream.javadsl.Flow<In,Out,?>	bypassWith(java.util.function.Function<In,F.Either<FlowIn,Out>> splitter, akka.stream.javadsl.Flow<FlowIn,Out,?> flow) Bypass the given flow using the given splitter function.

Methods inherited from class java.lang.Object

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

Constructor Detail

AkkaStreams

public AkkaStreams()

Method Detail

bypassWith

public static <In,FlowIn,Out> akka.stream.javadsl.Flow<In,Out,?> bypassWith(java.util.function.Function<In,F.Either<FlowIn,Out>> splitter,
                                                                            akka.stream.javadsl.Flow<FlowIn,Out,?> flow)

Bypass the given flow using the given splitter function. If the splitter function returns Left, they will go through the flow. If it returns Right, they will bypass the flow.

bypassWith

public static <In,FlowIn,Out> akka.stream.javadsl.Flow<In,Out,?> bypassWith(akka.stream.javadsl.Flow<In,F.Either<FlowIn,Out>,?> splitter,
                                                                            akka.stream.Graph<akka.stream.UniformFanInShape<Out,Out>,?> mergeStrategy,
                                                                            akka.stream.javadsl.Flow<FlowIn,Out,?> flow)

Using the given splitter flow, allow messages to bypass a flow. If the splitter flow produces Left, they will be fed into the flow. If it produces Right, they will bypass the flow.