Class ZipN<T>

Combine the elements of multiple streams into a stream of sequences. A ZipN<T> has a n input ports 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<UniformFanInShape<T, System.Collections.Immutable.IImmutableList<T>>, NotUsed>
GraphStage<UniformFanInShape<T, System.Collections.Immutable.IImmutableList<T>>>
ZipWithN<T, System.Collections.Immutable.IImmutableList<T>>
ZipN<T>
Implements
IGraphStageWithMaterializedValue<UniformFanInShape<T, System.Collections.Immutable.IImmutableList<T>>, NotUsed>
IGraph<UniformFanInShape<T, System.Collections.Immutable.IImmutableList<T>>, NotUsed>
IGraph<UniformFanInShape<T, System.Collections.Immutable.IImmutableList<T>>>
Inherited Members
Namespace: Akka.Streams.Dsl
Assembly: Akka.Streams.dll
Syntax
public sealed class ZipN<T> : ZipWithN<T, IImmutableList<T>>, IGraphStageWithMaterializedValue<UniformFanInShape<T, IImmutableList<T>>, NotUsed>, IGraph<UniformFanInShape<T, IImmutableList<T>>, NotUsed>, IGraph<UniformFanInShape<T, IImmutableList<T>>>
Type Parameters
Name Description
T

TBD

Constructors

| Improve this Doc View Source

ZipN(Int32)

Initializes a new instance of the ZipN<T> class.

Declaration
public ZipN(int n)
Parameters
Type Name Description
Int32 n

TBD

Properties

| Improve this Doc View Source

InitialAttributes

TBD

Declaration
protected override Attributes InitialAttributes { get; }
Property Value
Type Description
Attributes
Overrides
Akka.Streams.Dsl.ZipWithN<T, System.Collections.Immutable.IImmutableList<T>>.InitialAttributes

Methods

| Improve this Doc View Source

ToString()

TBD

Declaration
public override string ToString()
Returns
Type Description
String

TBD
Overrides
Akka.Streams.Dsl.ZipWithN<T, System.Collections.Immutable.IImmutableList<T>>.ToString()

Implements

Extension Methods