Package org.apache.pekko.stream.scaladsl
Class Unzip$
- java.lang.Object
-
- org.apache.pekko.stream.scaladsl.Unzip$
-
public class Unzip$ extends java.lang.Object
Takes a stream of pair elements and splits each pair to two output streams.An
Unzip
has onein
port and oneleft
and oneright
output port.'''Emits when''' all of the outputs stop backpressuring and there is an input element available
'''Backpressures when''' any of the outputs backpressure
'''Completes when''' upstream completes
'''Cancels when''' any downstream cancels
-
-
Constructor Summary
Constructors Constructor Description Unzip$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <A,B>
Unzip<A,B>apply()
Create a newUnzip
.
-