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 backpressuresCompletes when any upstream completes
Cancels when downstream cancelsImplements
IGraph<UniformFanInShape<TIn, TOut>>
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
| Edit this page View SourceZipWithN(Func<IImmutableList<TIn>, TOut>, int)
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<IImmutableList<TIn>, TOut> | zipper | TBD |
| int | n | TBD |
Properties
| Edit this page View SourceInitialAttributes
TBD
Declaration
protected override Attributes InitialAttributes { get; }Property Value
| Type | Description |
|---|---|
| Attributes |
Overrides
| Edit this page View SourceInlets
TBD
Declaration
public IImmutableList<Inlet<TIn>> Inlets { get; }Property Value
| Type | Description |
|---|---|
| IImmutableList<Inlet<TIn>> |
Out
TBD
Declaration
public Outlet<TOut> Out { get; }Property Value
| Type | Description |
|---|---|
| Outlet<TOut> |
Shape
TBD
Declaration
public override UniformFanInShape<TIn, TOut> Shape { get; }Property Value
| Type | Description |
|---|---|
| UniformFanInShape<TIn, TOut> |
Overrides
Methods
| Edit this page View SourceCreateLogic(Attributes)
TBD
Declaration
protected override GraphStageLogic CreateLogic(Attributes inheritedAttributes)Parameters
| Type | Name | Description |
|---|---|---|
| Attributes | inheritedAttributes | TBD |
Returns
| Type | Description |
|---|---|
| GraphStageLogic | TBD |
Overrides
| Edit this page View SourceIn(int)
TBD
Declaration
public Inlet<TIn> In(int i)Parameters
| Type | Name | Description |
|---|---|---|
| int | i | TBD |
Returns
| Type | Description |
|---|---|
| Inlet<TIn> | TBD |
ToString()
TBD
Declaration
public override string ToString()Returns
| Type | Description |
|---|---|
| string | TBD |
Edit this page