public class Unzip
extends java.lang.Object
An Unzip
has one in
port and one left
and one right
output port.
'''Emits when''' all of the outputs stops backpressuring and there is an input element available
'''Backpressures when''' any of the outputs backpressures
'''Completes when''' upstream completes
'''Cancels when''' any downstream cancels
Constructor and Description |
---|
Unzip() |
Modifier and Type | Method and Description |
---|---|
static <A,B> Graph<FanOutShape2<Pair<A,B>,A,B>,NotUsed> |
create()
Creates a new
Unzip stage with the specified output types. |
static <A,B> Graph<FanOutShape2<Pair<A,B>,A,B>,NotUsed> |
create(java.lang.Class<A> left,
java.lang.Class<B> right)
Creates a new
Unzip stage with the specified output types. |
public static <A,B> Graph<FanOutShape2<Pair<A,B>,A,B>,NotUsed> create()
Unzip
stage with the specified output types.public static <A,B> Graph<FanOutShape2<Pair<A,B>,A,B>,NotUsed> create(java.lang.Class<A> left, java.lang.Class<B> right)
Unzip
stage with the specified output types.left
- (undocumented)right
- (undocumented)