Package akka.stream.javadsl

Class MergePreferred

java.lang.Object

akka.stream.javadsl.MergePreferred

public class MergePreferred
extends java.lang.Object

Create a new MergePreferred operator with the specified output type.

Constructor Summary

Constructors

Constructor	Description
MergePreferred()

Method Summary

Modifier and Type	Method	Description
static <T> Graph<MergePreferred.MergePreferredShape<T>,NotUsed>	create(int secondaryPorts)
static <T> Graph<MergePreferred.MergePreferredShape<T>,NotUsed>	create(int secondaryPorts, boolean eagerComplete)	Create a new MergePreferred operator with the specified output type.
static <T> Graph<MergePreferred.MergePreferredShape<T>,NotUsed>	create(java.lang.Class<T> clazz, int secondaryPorts)	Create a new MergePreferred operator with the specified output type.
static <T> Graph<MergePreferred.MergePreferredShape<T>,NotUsed>	create(java.lang.Class<T> clazz, int secondaryPorts, boolean eagerComplete)	Create a new MergePreferred operator with the specified output type.

Methods inherited from class java.lang.Object

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

Constructor Detail

MergePreferred

public MergePreferred()

Method Detail

create

public static <T> Graph<MergePreferred.MergePreferredShape<T>,NotUsed> create(int secondaryPorts)

create

public static <T> Graph<MergePreferred.MergePreferredShape<T>,NotUsed> create(java.lang.Class<T> clazz,
                                                                                    int secondaryPorts)

Create a new MergePreferred operator with the specified output type.

Parameters:

clazz - (undocumented)

secondaryPorts - (undocumented)

Returns:

(undocumented)

create

public static <T> Graph<MergePreferred.MergePreferredShape<T>,NotUsed> create(int secondaryPorts,
                                                                                    boolean eagerComplete)

Create a new MergePreferred operator with the specified output type.

Parameters:

eagerComplete - set to true in order to make this operator eagerly finish as soon as one of its inputs completes

secondaryPorts - (undocumented)

Returns:

(undocumented)

create

public static <T> Graph<MergePreferred.MergePreferredShape<T>,NotUsed> create(java.lang.Class<T> clazz,
                                                                                    int secondaryPorts,
                                                                                    boolean eagerComplete)

Create a new MergePreferred operator with the specified output type.

Parameters:

eagerComplete - set to true in order to make this operator eagerly finish as soon as one of its inputs completes

clazz - (undocumented)

secondaryPorts - (undocumented)

Returns:

(undocumented)