Package akka.stream.javadsl

Class MergePrioritized

java.lang.Object

akka.stream.javadsl.MergePrioritized

public class MergePrioritized
extends java.lang.Object

Create a new MergePrioritized operator with the specified output type.

Constructor Summary

Constructors

Constructor	Description
MergePrioritized()

Method Summary

Modifier and Type	Method	Description
static <T> Graph<UniformFanInShape<T,T>,NotUsed>	create(int[] priorities)
static <T> Graph<UniformFanInShape<T,T>,NotUsed>	create(int[] priorities, boolean eagerComplete)	Create a new MergePrioritized operator with the specified output type.
static <T> Graph<UniformFanInShape<T,T>,NotUsed>	create(java.lang.Class<T> clazz, int[] priorities)	Create a new MergePrioritized operator with the specified output type.
static <T> Graph<UniformFanInShape<T,T>,NotUsed>	create(java.lang.Class<T> clazz, int[] priorities, boolean eagerComplete)	Create a new MergePrioritized 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

MergePrioritized

public MergePrioritized()

Method Detail

create

public static <T> Graph<UniformFanInShape<T,T>,NotUsed> create(int[] priorities)

create

public static <T> Graph<UniformFanInShape<T,T>,NotUsed> create(java.lang.Class<T> clazz,
                                                                           int[] priorities)

Create a new MergePrioritized operator with the specified output type.

Parameters:

clazz - (undocumented)

priorities - (undocumented)

Returns:

(undocumented)

create

public static <T> Graph<UniformFanInShape<T,T>,NotUsed> create(int[] priorities,
                                                                           boolean eagerComplete)

Create a new MergePrioritized 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

priorities - (undocumented)

Returns:

(undocumented)

create

public static <T> Graph<UniformFanInShape<T,T>,NotUsed> create(java.lang.Class<T> clazz,
                                                                           int[] priorities,
                                                                           boolean eagerComplete)

Create a new MergePrioritized 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)

priorities - (undocumented)

Returns:

(undocumented)