Class PartitionWith<TIn, TOut0, TOut1>

This stage partitions input to 2 different outlets, applying different transformations on the elements, according to the partition function.

Inheritance
Object
GraphStageWithMaterializedValue<FanOutShape<TIn, TOut0, TOut1>, NotUsed>
GraphStage<FanOutShape<TIn, TOut0, TOut1>>
PartitionWith<TIn, TOut0, TOut1>
Implements
IGraph<FanOutShape<TIn, TOut0, TOut1>, NotUsed>
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

| Improve this Doc View Source

PartitionWith(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

| Improve this Doc View Source

Shape

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

Methods

| Improve this Doc View Source

CreateLogic(Attributes)

Declaration
protected override GraphStageLogic CreateLogic(Attributes inheritedAttributes)
Parameters
Type Name Description
Attributes inheritedAttributes
Returns
Type Description
GraphStageLogic
Overrides
Akka.Streams.Stage.GraphStage<Akka.Streams.FanOutShape<TIn, TOut0, TOut1>>.CreateLogic(Akka.Streams.Attributes)

Implements

Extension Methods