public final class Zip<A,B> extends ZipWith2<A,B,scala.Tuple2<A,B>>
A Zip
has a left
and a right
input port 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 |
---|
Zip() |
Modifier and Type | Method and Description |
---|---|
static Graph<S,M> |
addAttributes(Attributes attr) |
static <A,B> Zip<A,B> |
apply()
Create a new
Zip . |
static Graph<S,M> |
async() |
static GraphStageLogic |
createLogic(Attributes inheritedAttributes) |
static scala.Tuple2<GraphStageLogic,NotUsed> |
createLogicAndMaterializedValue(Attributes inheritedAttributes) |
static Inlet<A1> |
in0() |
static Inlet<A2> |
in1() |
static Attributes |
initialAttributes() |
static StreamLayout.Module |
module() |
static Graph<S,M> |
named(java.lang.String name) |
static Outlet<O> |
out() |
static FanInShape2<A1,A2,O> |
shape() |
java.lang.String |
toString() |
static Graph<S,M> |
withAttributes(Attributes attr) |
static scala.Function2<A1,A2,O> |
zipper() |
createLogic, in0, in1, initialAttributes, out, shape, zipper
createLogicAndMaterializedValue
module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addAttributes, async, named
public static <A,B> Zip<A,B> apply()
Zip
.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 static scala.Function2<A1,A2,O> zipper()
public static Attributes initialAttributes()
public static FanInShape2<A1,A2,O> shape()
public static Outlet<O> out()
public static Inlet<A1> in0()
public static Inlet<A2> in1()
public static GraphStageLogic createLogic(Attributes inheritedAttributes)