Class PartitionWith<TIn, TOut0, TOut1>
This stage partitions input to 2 different outlets, applying different transformations on the elements, according to the partition function.
Implements
IGraph<FanOutShape<TIn, TOut0, TOut1>>
Inherited Members
Namespace: Akka.Streams.Dsl
Assembly: Akka.Streams.dll
Syntax
public class PartitionWith<TIn, TOut0, TOut1> : GraphStage<FanOutShape<TIn, TOut0, TOut1>>, IGraphStageWithMaterializedValue<FanOutShape<TIn, TOut0, TOut1>, NotUsed>, IGraph<FanOutShape<TIn, TOut0, TOut1>, NotUsed>, IGraph<FanOutShape<TIn, TOut0, TOut1>>
Type Parameters
Name | Description |
---|---|
TIn | input type |
TOut0 | left output type |
TOut1 | right output type |
Constructors
| Edit this page View SourcePartitionWith(Func<TIn, Either<TOut0, TOut1>>)
Declaration
public PartitionWith(Func<TIn, Either<TOut0, TOut1>> partitionWith)
Parameters
Type | Name | Description |
---|---|---|
Func<TIn, Either<TOut0, TOut1>> | partitionWith | partition function |
Properties
| Edit this page View SourceShape
TBD
Declaration
public override FanOutShape<TIn, TOut0, TOut1> Shape { get; }
Property Value
Type | Description |
---|---|
FanOutShape<TIn, TOut0, TOut1> |
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 |