Search Results for

    Show / Hide Table of Contents

    Interface IFlow<TOut, TMat>

    Operations offered by Sources and Flows with a free output side: the DSL flows left-to-right only.

    Namespace: Akka.Streams.Dsl
    Assembly: Akka.Streams.dll
    Syntax
    public interface IFlow<TOut, out TMat>
    Type Parameters
    Name Description
    TOut

    TBD

    TMat

    TBD

    Methods

    | Edit this page View Source

    MapMaterializedValue<TMat2>(Func<TMat, TMat2>)

    Transform the materialized value of this Flow, leaving all other properties as they were.

    Declaration
    IFlow<TOut, TMat2> MapMaterializedValue<TMat2>(Func<out TMat, TMat2> mapFunc)
    Parameters
    Type Name Description
    Func<TMat, TMat2> mapFunc

    TBD

    Returns
    Type Description
    IFlow<TOut, TMat2>

    TBD

    Type Parameters
    Name Description
    TMat2

    TBD

    | Edit this page View Source

    ViaMaterialized<T2, TMat2, TMat3>(IGraph<FlowShape<TOut, T2>, TMat2>, Func<TMat, TMat2, TMat3>)

    Transform this IFlow<TOut, TMat> by appending the given processing steps. The combine function is used to compose the materialized values of this flow and that flow into the materialized value of the resulting Flow.

    Declaration
    IFlow<T2, TMat3> ViaMaterialized<T2, TMat2, TMat3>(IGraph<FlowShape<TOut, T2>, TMat2> flow, Func<out TMat, TMat2, TMat3> combine)
    Parameters
    Type Name Description
    IGraph<FlowShape<TOut, T2>, TMat2> flow

    TBD

    Func<TMat, TMat2, TMat3> combine

    TBD

    Returns
    Type Description
    IFlow<T2, TMat3>

    TBD

    Type Parameters
    Name Description
    T2

    TBD

    TMat2

    TBD

    TMat3

    TBD

    | Edit this page View Source

    Via<T, TMat2>(IGraph<FlowShape<TOut, T>, TMat2>)

    Transform this IFlow<TOut, TMat> by appending the given processing steps. The materialized value of the combined IFlow<TOut, TMat> will be the materialized value of the current flow (ignoring the other flow’s value), use ViaMaterialized<T2, TMat2, TMat3>(IGraph<FlowShape<TOut, T2>, TMat2>, Func<TMat, TMat2, TMat3>) if a different strategy is needed.

    Declaration
    IFlow<T, out TMat> Via<T, TMat2>(IGraph<FlowShape<TOut, T>, TMat2> flow)
    Parameters
    Type Name Description
    IGraph<FlowShape<TOut, T>, TMat2> flow

    TBD

    Returns
    Type Description
    IFlow<T, TMat>

    TBD

    Type Parameters
    Name Description
    T

    TBD

    TMat2

    TBD

    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