public class ZipWithN<A,O> extends GraphStage<UniformFanInShape<A,O>>
A ZipWithN
has a n
input ports and one out
port
'''Emits when''' all of the inputs has an element available
'''Backpressures when''' downstream backpressures
'''Completes when''' any upstream completes
'''Cancels when''' downstream cancels
Constructor and Description |
---|
ZipWithN(scala.Function1<scala.collection.immutable.Seq<A>,O> zipper,
int n) |
Modifier and Type | Method and Description |
---|---|
static Graph<S,M> |
addAttributes(Attributes attr) |
static <A,O> ZipWithN<A,O> |
apply(scala.Function1<scala.collection.immutable.Seq<A>,O> zipper,
int n)
Create a new
ZipWithN . |
static Graph<S,M> |
async() |
GraphStageLogic |
createLogic(Attributes inheritedAttributes) |
static scala.Tuple2<GraphStageLogic,NotUsed> |
createLogicAndMaterializedValue(Attributes inheritedAttributes) |
Attributes |
initialAttributes() |
scala.collection.immutable.IndexedSeq<Inlet<A>> |
inSeq() |
static StreamLayout.Module |
module() |
static Graph<S,M> |
named(java.lang.String name) |
Outlet<O> |
out() |
UniformFanInShape<A,O> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
java.lang.String |
toString() |
static Graph<S,M> |
withAttributes(Attributes attr) |
createLogicAndMaterializedValue
module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addAttributes, async, named
public static <A,O> ZipWithN<A,O> apply(scala.Function1<scala.collection.immutable.Seq<A>,O> zipper, int n)
ZipWithN
.zipper
- (undocumented)n
- (undocumented)public static Graph<S,M> named(java.lang.String name)
public static Graph<S,M> async()
public static Graph<S,M> addAttributes(Attributes attr)
public static final StreamLayout.Module module()
public static final Graph<S,M> withAttributes(Attributes attr)
public static final scala.Tuple2<GraphStageLogic,NotUsed> createLogicAndMaterializedValue(Attributes inheritedAttributes)
public Attributes initialAttributes()
initialAttributes
in class GraphStageWithMaterializedValue<UniformFanInShape<A,O>,NotUsed>
public UniformFanInShape<A,O> shape()
Graph
public GraphStageLogic createLogic(Attributes inheritedAttributes)
createLogic
in class GraphStage<UniformFanInShape<A,O>>
public java.lang.String toString()
toString
in class java.lang.Object