Class Zip<T1, T2>

Combine the elements of 2 streams into a stream of tuples.

A Zip<T1, T2> has a left and a right input port and one out port

Emits when all of the inputs has an element available

Backpressures when downstream backpressures

Completes when any upstream completes

Cancels when downstream cancels
Inheritance
object
GraphStageWithMaterializedValue<FanInShape<T1, T2, (T1, T2)>, NotUsed>
GraphStage<FanInShape<T1, T2, (T1, T2)>>
ZipWith<T1, T2, (T1, T2)>
Zip<T1, T2>
Implements
IGraph<FanInShape<T1, T2, (T1, T2)>, NotUsed>
IGraph<FanInShape<T1, T2, (T1, T2)>>
Inherited Members
Namespace: Akka.Streams.Dsl
Assembly: Akka.Streams.dll
Syntax
public sealed class Zip<T1, T2> : ZipWith<T1, T2, (T1, T2)>, IGraphStageWithMaterializedValue<FanInShape<T1, T2, (T1, T2)>, NotUsed>, IGraph<FanInShape<T1, T2, (T1, T2)>, NotUsed>, IGraph<FanInShape<T1, T2, (T1, T2)>>
Type Parameters
Name Description
T1

TBD
T2

TBD

Constructors

| Edit this page View Source

Zip()

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

Declaration
public Zip()

Methods

| Edit this page View Source

ToString()

TBD

Declaration
public override string ToString()
Returns
Type Description
string

TBD
Overrides

Implements

Extension Methods