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.
-
-
Field Summary
Fields Modifier and Type Field Description static Broadcast$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description Broadcast$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> Graph<UniformFanOutShape<T,T>,NotUsed>
create(int outputCount)
Create a newBroadcast
operator with the specified input type.<T> Graph<UniformFanOutShape<T,T>,NotUsed>
create(int outputCount, boolean eagerCancel)
<T> Graph<UniformFanOutShape<T,T>,NotUsed>
create(java.lang.Class<T> clazz, int outputCount)
Create a newBroadcast
operator with the specified input type.
-
-
-
Field Detail
-
MODULE$
public static final Broadcast$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
create
public <T> Graph<UniformFanOutShape<T,T>,NotUsed> create(int outputCount, boolean eagerCancel)
-
create
public <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 <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)
-
-