Class Partition<T>

Fan-out the stream to several streams. emitting an incoming upstream element to one downstream consumer according to the partitioner function applied to the element

Emits when an element is available from the input and the chosen output has demand

Backpressures when the currently chosen output back-pressures

Completes when upstream completes and no output is pending

Cancels when when all downstreams cancel

Inheritance
Object
GraphStageWithMaterializedValue<UniformFanOutShape<T, T>, NotUsed>
GraphStage<UniformFanOutShape<T, T>>
Partition<T>
Implements
Inherited Members
Namespace: Akka.Streams.Dsl
Assembly: Akka.Streams.dll
Syntax
public sealed class Partition<T> : GraphStage<UniformFanOutShape<T, T>>, IGraphStageWithMaterializedValue<UniformFanOutShape<T, T>, NotUsed>, IGraph<UniformFanOutShape<T, T>, NotUsed>, IGraph<UniformFanOutShape<T, T>>
Type Parameters
Name Description
T

TBD

Constructors

| Improve this Doc View Source

Partition(Int32, Func<T, Int32>)

Initializes a new instance of the Partition<T> class.

Declaration
public Partition(int outputPorts, Func<T, int> partitioner)
Parameters
Type Name Description
Int32 outputPorts

TBD
Func<T, Int32> partitioner

TBD

Fields

| Improve this Doc View Source

In

TBD

Declaration
public readonly Inlet<T> In
Field Value
Type Description
Inlet<T>

Properties

| Improve this Doc View Source

Shape

TBD

Declaration
public override UniformFanOutShape<T, T> Shape { get; }
Property Value
Type Description
UniformFanOutShape<T, T>
Overrides
Akka.Streams.Stage.GraphStageWithMaterializedValue<Akka.Streams.UniformFanOutShape<T, T>, 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.UniformFanOutShape<T, T>>.CreateLogic(Akka.Streams.Attributes)
| Improve this Doc View Source

Out(Int32)

TBD

Declaration
public Outlet<T> Out(int id)
Parameters
Type Name Description
Int32 id

TBD
Returns
Type Description
Outlet<T>

TBD
| Improve this Doc View Source

ToString()

TBD

Declaration
public override string ToString()
Returns
Type Description
String

TBD
Overrides

Implements

Extension Methods