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 backpressure

Completes when upstream completes

Cancels when any downstream cancels
Inheritance
object
GraphStageWithMaterializedValue<FanOutShape<KeyValuePair<T1, T2>, T1, T2>, NotUsed>
GraphStage<FanOutShape<KeyValuePair<T1, T2>, T1, T2>>
UnzipWith<KeyValuePair<T1, T2>, T1, T2>
UnZip<T1, T2>
Implements
IGraph<FanOutShape<KeyValuePair<T1, T2>, T1, T2>>
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

| Edit this page View Source

UnZip()

Initializes a new instance of the UnZip<T1, T2> class.

Declaration
public UnZip()

Methods

| Edit this page View Source

ToString()

TBD

Declaration
public override string ToString()
Returns
Type Description
string

TBD
Overrides

Implements

Extension Methods