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, System.ValueTuple<T1, T2>>, NotUsed>
GraphStage<FanInShape<T1, T2, System.ValueTuple<T1, T2>>>
ZipWith<T1, T2, System.ValueTuple<T1, T2>>
Zip<T1, T2>
Implements
IGraphStageWithMaterializedValue<FanInShape<T1, T2, System.ValueTuple<T1, T2>>, NotUsed>
IGraph<FanInShape<T1, T2, System.ValueTuple<T1, T2>>, NotUsed>
IGraph<FanInShape<T1, T2, System.ValueTuple<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

| Improve this Doc View Source

Zip()

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

Declaration
public Zip()

Methods

| Improve this Doc View Source

ToString()

TBD

Declaration
public override string ToString()
Returns
Type Description
String

TBD
Overrides

Implements

Extension Methods