Search Results for

    Show / Hide Table of Contents

    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
    IGraphStageWithMaterializedValue<UniformFanOutShape<T, T>, NotUsed>
    IGraph<UniformFanOutShape<T, T>, NotUsed>
    IGraph<UniformFanOutShape<T, T>>
    Inherited Members
    GraphStage<UniformFanOutShape<T, T>>.CreateLogicAndMaterializedValue(Attributes)
    GraphStageWithMaterializedValue<UniformFanOutShape<T, T>, NotUsed>.Shape
    GraphStageWithMaterializedValue<UniformFanOutShape<T, T>, NotUsed>.WithAttributes(Attributes)
    GraphStageWithMaterializedValue<UniformFanOutShape<T, T>, NotUsed>.CreateLogicAndMaterializedValue(Attributes)
    GraphStageWithMaterializedValue<UniformFanOutShape<T, T>, NotUsed>.Module
    GraphStageWithMaterializedValue<UniformFanOutShape<T, T>, NotUsed>.AddAttributes(Attributes)
    GraphStageWithMaterializedValue<UniformFanOutShape<T, T>, NotUsed>.Named(string)
    GraphStageWithMaterializedValue<UniformFanOutShape<T, T>, NotUsed>.Async()
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.ReferenceEquals(object, object)
    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
    GraphStageWithMaterializedValue<UniformFanOutShape<T, T>, NotUsed>.Shape

    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
    GraphStage<UniformFanOutShape<T, T>>.CreateLogic(Attributes)
    | 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
    object.ToString()

    Implements

    IGraphStageWithMaterializedValue<TShape, TMaterialized>
    IGraph<TShape, TMaterialized>
    IGraph<TShape>

    Extension Methods

    ObjectExtensions.IsDefaultForType<T>(T)
    ObjectExtensions.AsOption<T>(T)
    Extensions.AsInstanceOf<T>(object)
    In this article
    • githubEdit this page
    • View Source
    Back to top
    Contribute
    • Project Chat
    • Discussion Forum
    • Source Code
    Support
    • Akka.NET Support Plans
    • Akka.NET Observability Tools
    • Akka.NET Training & Consulting
    Maintained By
    • Petabridge - The Akka.NET Company
    • Learn Akka.NET