Class UnZip<T1, T2>
Takes a stream of pair elements and splits each pair to two output streams.
An UnZip<T1, T2> 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 backpressureCompletes when upstream completes
Cancels when any downstream cancelsImplements
Inherited Members
Namespace: Akka.Streams.Dsl
Assembly: Akka.Streams.dll
Syntax
public sealed class UnZip<T1, T2> : UnzipWith<KeyValuePair<T1, T2>, T1, T2>, IGraphStageWithMaterializedValue<FanOutShape<KeyValuePair<T1, T2>, T1, T2>, NotUsed>, IGraph<FanOutShape<KeyValuePair<T1, T2>, T1, T2>, NotUsed>, IGraph<FanOutShape<KeyValuePair<T1, T2>, T1, T2>>Type Parameters
| Name | Description |
|---|---|
| T1 | TBD |
| T2 | TBD |
Constructors
| Improve this Doc View SourceUnZip()
Initializes a new instance of the UnZip<T1, T2> class.
Declaration
public UnZip()Methods
| Improve this Doc View SourceToString()
TBD
Declaration
public override string ToString()Returns
| Type | Description |
|---|---|
| String | TBD |
Improve this Doc