Class ZipWithN<TIn, TOut>

Combine the elements of multiple streams into a stream of sequences using a combiner function. A ZipWithN<TIn, TOut> 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<TIn, TOut>, NotUsed>
GraphStage<UniformFanInShape<TIn, TOut>>
ZipWithN<TIn, TOut>
ZipN<T>
Implements
Inherited Members
Namespace: Akka.Streams.Dsl
Assembly: Akka.Streams.dll
Syntax
public class ZipWithN<TIn, TOut> : GraphStage<UniformFanInShape<TIn, TOut>>, IGraphStageWithMaterializedValue<UniformFanInShape<TIn, TOut>, NotUsed>, IGraph<UniformFanInShape<TIn, TOut>, NotUsed>, IGraph<UniformFanInShape<TIn, TOut>>
Type Parameters
Name Description
TIn

TBD
TOut

TBD

Constructors

| Improve this Doc View Source

ZipWithN(Func<IImmutableList<TIn>, TOut>, Int32)

Initializes a new instance of the ZipWithN<TIn, TOut> class.

Declaration
public ZipWithN(Func<IImmutableList<TIn>, TOut> zipper, int n)
Parameters
Type Name Description
Func<System.Collections.Immutable.IImmutableList<TIn>, TOut> zipper

TBD
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.Stage.GraphStageWithMaterializedValue<Akka.Streams.UniformFanInShape<TIn, TOut>, Akka.NotUsed>.InitialAttributes
| Improve this Doc View Source

Inlets

TBD

Declaration
public IImmutableList<Inlet<TIn>> Inlets { get; }
Property Value
Type Description
System.Collections.Immutable.IImmutableList<Inlet<TIn>>
| Improve this Doc View Source

Out

TBD

Declaration
public Outlet<TOut> Out { get; }
Property Value
Type Description
Outlet<TOut>
| Improve this Doc View Source

Shape

TBD

Declaration
public override UniformFanInShape<TIn, TOut> Shape { get; }
Property Value
Type Description
UniformFanInShape<TIn, TOut>
Overrides
Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.UniformFanInShape<TIn, TOut>, Akka.NotUsed>.Shape

Methods

| Improve this Doc View Source

CreateLogic(Attributes)

TBD

Declaration
protected override GraphStageLogic CreateLogic(Attributes inheritedAttributes)
Parameters
Type Name Description
Attributes inheritedAttributes

TBD
Returns
Type Description
GraphStageLogic

TBD
Overrides
Akka.Streams.Stage.GraphStage<Akka.Streams.UniformFanInShape<TIn, TOut>>.CreateLogic(Akka.Streams.Attributes)
| Improve this Doc View Source

In(Int32)

TBD

Declaration
public Inlet<TIn> In(int i)
Parameters
Type Name Description
Int32 i

TBD
Returns
Type Description
Inlet<TIn>

TBD
| Improve this Doc View Source

ToString()

TBD

Declaration
public override string ToString()
Returns
Type Description
String

TBD
Overrides

Implements

Extension Methods