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
Implements
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