public class Zip$
extends java.lang.Object
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
Modifier and Type | Field and Description |
---|---|
static Zip$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
Zip$() |
Modifier and Type | Method and Description |
---|---|
<A,B> Graph<FanInShape2<A,B,Pair<A,B>>,NotUsed> |
create()
Create a new
Zip stage with the specified input types and zipping-function
which creates akka.japi.Pair s. |
public static final Zip$ MODULE$
public <A,B> Graph<FanInShape2<A,B,Pair<A,B>>,NotUsed> create()
Zip
stage with the specified input types and zipping-function
which creates akka.japi.Pair
s.