Package akka.stream.javadsl
Class Broadcast
- java.lang.Object
-
- akka.stream.javadsl.Broadcast
-
public class Broadcast extends java.lang.Object
Create a newBroadcast
operator with the specified input type.param: outputCount number of output ports param: eagerCancel if true, broadcast cancels upstream if any of its downstreams cancel.
-
-
Constructor Summary
Constructors Constructor Description Broadcast()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> Graph<UniformFanOutShape<T,T>,NotUsed>
create(int outputCount)
Create a newBroadcast
operator with the specified input type.static <T> Graph<UniformFanOutShape<T,T>,NotUsed>
create(int outputCount, boolean eagerCancel)
static <T> Graph<UniformFanOutShape<T,T>,NotUsed>
create(java.lang.Class<T> clazz, int outputCount)
Create a newBroadcast
operator with the specified input type.
-
-
-
Method Detail
-
create
public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(int outputCount, boolean eagerCancel)
-
create
public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(int outputCount)
Create a newBroadcast
operator with the specified input type.- Parameters:
outputCount
- number of output ports- Returns:
- (undocumented)
-
create
public static <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(java.lang.Class<T> clazz, int outputCount)
Create a newBroadcast
operator with the specified input type.- Parameters:
clazz
- (undocumented)outputCount
- (undocumented)- Returns:
- (undocumented)
-
-