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, IImmutableList<T>>, NotUsed>

GraphStage<UniformFanInShape<T, IImmutableList<T>>>

ZipWithN<T, IImmutableList<T>>

ZipN<T>

Implements

IGraphStageWithMaterializedValue<UniformFanInShape<T, IImmutableList<T>>, NotUsed>

IGraph<UniformFanInShape<T, IImmutableList<T>>, NotUsed>

IGraph<UniformFanInShape<T, IImmutableList<T>>>

Inherited Members

ZipWithN<T, IImmutableList<T>>.Out

ZipWithN<T, IImmutableList<T>>.Inlets

ZipWithN<T, IImmutableList<T>>.In(int)

ZipWithN<T, IImmutableList<T>>.Shape

ZipWithN<T, IImmutableList<T>>.ToString()

GraphStage<UniformFanInShape<T, IImmutableList<T>>>.CreateLogicAndMaterializedValue(Attributes)

GraphStageWithMaterializedValue<UniformFanInShape<T, IImmutableList<T>>, NotUsed>.Shape

GraphStageWithMaterializedValue<UniformFanInShape<T, IImmutableList<T>>, NotUsed>.WithAttributes(Attributes)

GraphStageWithMaterializedValue<UniformFanInShape<T, IImmutableList<T>>, NotUsed>.CreateLogicAndMaterializedValue(Attributes)

GraphStageWithMaterializedValue<UniformFanInShape<T, IImmutableList<T>>, NotUsed>.Module

GraphStageWithMaterializedValue<UniformFanInShape<T, IImmutableList<T>>, NotUsed>.AddAttributes(Attributes)

GraphStageWithMaterializedValue<UniformFanInShape<T, IImmutableList<T>>, NotUsed>.Named(string)

GraphStageWithMaterializedValue<UniformFanInShape<T, IImmutableList<T>>, NotUsed>.Async()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

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

ZipN(int)

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

Declaration

public ZipN(int n)

Parameters

Type	Name	Description
int	n	TBD

Properties

InitialAttributes

TBD

Declaration

protected override Attributes InitialAttributes { get; }

Property Value

Type	Description
Attributes

Overrides

ZipWithN<T, IImmutableList<T>>.InitialAttributes

Methods

ToString()

TBD

Declaration

public override string ToString()

Returns

Type	Description
string	TBD

Overrides

ZipWithN<T, IImmutableList<T>>.ToString()

Implements

IGraphStageWithMaterializedValue<TShape, TMaterialized>

IGraph<TShape, TMaterialized>

IGraph<TShape>

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)