Package akka.stream.javadsl

Class Broadcast

java.lang.Object

akka.stream.javadsl.Broadcast

public class Broadcast
extends java.lang.Object

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

Modifier and Type	Method	Description
static <T> Graph<UniformFanOutShape<T,T>,NotUsed>	create(int outputCount)	Create a new Broadcast 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 new Broadcast operator with the specified input type.

Methods inherited from class java.lang.Object

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

Constructor Detail

Broadcast

public Broadcast()

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 new Broadcast 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 new Broadcast operator with the specified input type.

Parameters:

clazz - (undocumented)

outputCount - (undocumented)

Returns:

(undocumented)