Package akka.stream.scaladsl
Class Unzip$
- java.lang.Object
-
- akka.stream.scaladsl.Unzip$
-
public class Unzip$ extends java.lang.ObjectTakes a stream of pair elements and splits each pair to two output streams.An
Unziphas oneinport and oneleftand onerightoutput 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.
-