Search Results for

    Show / Hide Table of Contents

    Interface IModule

    TBD

    Inherited Members
    IComparable<IModule>.CompareTo(IModule)
    Namespace: Akka.Streams.Implementation
    Assembly: Akka.Streams.dll
    Syntax
    public interface IModule : IComparable<IModule>

    Properties

    | Edit this page View Source

    Attributes

    TBD

    Declaration
    Attributes Attributes { get; }
    Property Value
    Type Description
    Attributes
    | Edit this page View Source

    Downstreams

    TBD

    Declaration
    IImmutableDictionary<OutPort, InPort> Downstreams { get; }
    Property Value
    Type Description
    IImmutableDictionary<OutPort, InPort>
    | Edit this page View Source

    InPorts

    TBD

    Declaration
    IImmutableSet<InPort> InPorts { get; }
    Property Value
    Type Description
    IImmutableSet<InPort>
    | Edit this page View Source

    IsAtomic

    TBD

    Declaration
    bool IsAtomic { get; }
    Property Value
    Type Description
    bool
    | Edit this page View Source

    IsBidiFlow

    TBD

    Declaration
    bool IsBidiFlow { get; }
    Property Value
    Type Description
    bool
    | Edit this page View Source

    IsCopied

    TBD

    Declaration
    bool IsCopied { get; }
    Property Value
    Type Description
    bool
    | Edit this page View Source

    IsFlow

    TBD

    Declaration
    bool IsFlow { get; }
    Property Value
    Type Description
    bool
    | Edit this page View Source

    IsRunnable

    TBD

    Declaration
    bool IsRunnable { get; }
    Property Value
    Type Description
    bool
    | Edit this page View Source

    IsSealed

    TBD

    Declaration
    bool IsSealed { get; }
    Property Value
    Type Description
    bool
    | Edit this page View Source

    IsSink

    TBD

    Declaration
    bool IsSink { get; }
    Property Value
    Type Description
    bool
    | Edit this page View Source

    IsSource

    TBD

    Declaration
    bool IsSource { get; }
    Property Value
    Type Description
    bool
    | Edit this page View Source

    MaterializedValueComputation

    TBD

    Declaration
    StreamLayout.IMaterializedValueNode MaterializedValueComputation { get; }
    Property Value
    Type Description
    StreamLayout.IMaterializedValueNode
    | Edit this page View Source

    OutPorts

    TBD

    Declaration
    IImmutableSet<OutPort> OutPorts { get; }
    Property Value
    Type Description
    IImmutableSet<OutPort>
    | Edit this page View Source

    Shape

    TBD

    Declaration
    Shape Shape { get; }
    Property Value
    Type Description
    Shape
    | Edit this page View Source

    SubModules

    TBD

    Declaration
    ImmutableArray<IModule> SubModules { get; }
    Property Value
    Type Description
    ImmutableArray<IModule>
    | Edit this page View Source

    Upstreams

    TBD

    Declaration
    IImmutableDictionary<InPort, OutPort> Upstreams { get; }
    Property Value
    Type Description
    IImmutableDictionary<InPort, OutPort>

    Methods

    | Edit this page View Source

    CarbonCopy()

    TBD

    Declaration
    IModule CarbonCopy()
    Returns
    Type Description
    IModule

    TBD

    | Edit this page View Source

    Compose(IModule)

    Creates a new Module which is this Module composed with that Module.

    Declaration
    IModule Compose(IModule that)
    Parameters
    Type Name Description
    IModule that

    A Module to be composed with (cannot be itself)

    Returns
    Type Description
    IModule

    A Module that represents the composition of this and that

    | Edit this page View Source

    ComposeNoMaterialized(IModule)

    Creates a new Module which is this Module composed with that Module.

    The difference to compose(that) is that this version completely ignores the materialized value computation of that while the normal version executes the computation and discards its result. This means that this version must not be used for user-provided that modules because users may transform materialized values only to achieve some side-effect; it can only be used where we know that there is no meaningful computation to be done (like for MaterializedValueSource).

    Declaration
    IModule ComposeNoMaterialized(IModule that)
    Parameters
    Type Name Description
    IModule that

    a Module to be composed with (cannot be itself)

    Returns
    Type Description
    IModule

    a Module that represents the composition of this and that

    | Edit this page View Source

    Compose<T1, T2, T3>(IModule, Func<T1, T2, T3>)

    Creates a new Module which is this Module composed with that Module, using the given function matFunc to compose the materialized value of this with the materialized value of that.

    Declaration
    IModule Compose<T1, T2, T3>(IModule that, Func<T1, T2, T3> matFunc)
    Parameters
    Type Name Description
    IModule that

    A Module to be composed with (cannot be itself)

    Func<T1, T2, T3> matFunc

    A function which combines the materialized values

    Returns
    Type Description
    IModule

    A Module that represents the composition of this and that

    Type Parameters
    Name Description
    T1

    The type of the materialized value of this

    T2

    The type of the materialized value of that

    T3

    The type of the materialized value of the returned Module

    | Edit this page View Source

    Fuse(IModule, OutPort, InPort)

    Fuses this Module to that Module by wiring together from and to, retaining the materialized value of this in the result

    Declaration
    IModule Fuse(IModule that, OutPort from, InPort to)
    Parameters
    Type Name Description
    IModule that

    A module to fuse with

    OutPort from

    The data source to wire

    InPort to

    The data sink to wire

    Returns
    Type Description
    IModule

    A module representing fusion of this and that

    | Edit this page View Source

    Fuse<T1, T2, T3>(IModule, OutPort, InPort, Func<T1, T2, T3>)

    Fuses this Module to that Module by wiring together from and to, retaining the materialized value of this in the result, using the provided function matFunc.

    Declaration
    IModule Fuse<T1, T2, T3>(IModule that, OutPort from, InPort to, Func<T1, T2, T3> matFunc)
    Parameters
    Type Name Description
    IModule that

    A module to fuse with

    OutPort from

    The data source to wire

    InPort to

    The data sink to wire

    Func<T1, T2, T3> matFunc

    The function to apply to the materialized values

    Returns
    Type Description
    IModule

    A module representing fusion of this and that

    Type Parameters
    Name Description
    T1

    TBD

    T2

    TBD

    T3

    TBD

    | Edit this page View Source

    Nest()

    Creates a new Module which contains this Module

    Declaration
    IModule Nest()
    Returns
    Type Description
    IModule

    TBD

    | Edit this page View Source

    ReplaceShape(Shape)

    Verify that the given Shape has the same ports and return a new module with that shape. Concrete implementations may throw UnsupportedOperationException where applicable.

    Declaration
    IModule ReplaceShape(Shape shape)
    Parameters
    Type Name Description
    Shape shape

    TBD

    Returns
    Type Description
    IModule

    TBD

    | Edit this page View Source

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

    TBD

    Declaration
    IModule TransformMaterializedValue<TMat, TMat2>(Func<TMat, TMat2> mapFunc)
    Parameters
    Type Name Description
    Func<TMat, TMat2> mapFunc

    TBD

    Returns
    Type Description
    IModule

    TBD

    Type Parameters
    Name Description
    TMat

    TBD

    TMat2

    TBD

    | Edit this page View Source

    Wire(OutPort, InPort)

    Creates a new Module based on the current Module but with the given OutPort wired to the given InPort.

    Declaration
    IModule Wire(OutPort from, InPort to)
    Parameters
    Type Name Description
    OutPort from

    The OutPort to wire.

    InPort to

    The InPort to wire.

    Returns
    Type Description
    IModule

    A new Module with the ports wired

    | Edit this page View Source

    WithAttributes(Attributes)

    TBD

    Declaration
    IModule WithAttributes(Attributes attributes)
    Parameters
    Type Name Description
    Attributes attributes

    TBD

    Returns
    Type Description
    IModule

    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