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

| Edit this page View Source

Partition(int, Func<T, int>)

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

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

TBD
Func<T, int> partitioner

TBD

Fields

| Edit this page View Source

In

TBD

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

Properties

| Edit this page View Source

Shape

TBD

Declaration
public override UniformFanOutShape<T, T> Shape { get; }
Property Value
Type Description
UniformFanOutShape<T, T>
Overrides

Methods

| Edit this page 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
| Edit this page View Source

Out(int)

TBD

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

TBD
Returns
Type Description
Outlet<T>

TBD
| Edit this page View Source

ToString()

TBD

Declaration
public override string ToString()
Returns
Type Description
string

TBD
Overrides

Implements

Extension Methods