Search Results for

    Show / Hide Table of Contents

    Class GraphStage<TShape>

    A GraphStage represents a reusable graph stream processing stage. A GraphStage consists of a Shape which describes its input and output ports and a factory function that creates a GraphStageLogic which implements the processing logic that ties the ports together.

    Inheritance
    object
    GraphStageWithMaterializedValue<TShape, NotUsed>
    GraphStage<TShape>
    AccumulateWhileUnchanged<TElement, TProperty>
    Balance<T>
    Broadcast<T>
    Concat<TIn, TOut>
    Interleave<TIn, TOut>
    KeepAliveConcat<T>
    MergePreferred<T>
    MergePrioritized<T>
    MergeSorted<T>
    Merge<TIn, TOut>
    One2OneBidi<TIn, TOut>
    OrElse<T>
    PartitionWith<TIn, TOut0, TOut1>
    Partition<T>
    ReuseLatest<T>
    Sample<T>
    UnzipWith<TIn, T0, T1>
    UnzipWith<TIn, T0, T1, T2>
    UnzipWith<TIn, T0, T1, T2, T3>
    UnzipWith<TIn, T0, T1, T2, T3, T4>
    UnzipWith<TIn, T0, T1, T2, T3, T4, T5>
    UnzipWith<TIn, T0, T1, T2, T3, T4, T5, T6>
    ZipWithN<TIn, TOut>
    ZipWith<TIn0, TIn1, TIn2, TIn3, TIn4, TIn5, TIn6, TIn7, TIn8, TOut>
    ZipWith<TIn0, TIn1, TOut>
    ZipWith<TIn0, TIn1, TIn2, TOut>
    ZipWith<TIn0, TIn1, TIn2, TIn3, TOut>
    ZipWith<TIn0, TIn1, TIn2, TIn3, TIn4, TOut>
    ZipWith<TIn0, TIn1, TIn2, TIn3, TIn4, TIn5, TOut>
    ZipWith<TIn0, TIn1, TIn2, TIn3, TIn4, TIn5, TIn6, TOut>
    ZipWith<TIn0, TIn1, TIn2, TIn3, TIn4, TIn5, TIn6, TIn7, TOut>
    EmptySource<TOut>
    SingleSource<T>
    TaskSource<T>
    Implements
    IGraphStageWithMaterializedValue<TShape, NotUsed>
    IGraph<TShape, NotUsed>
    IGraph<TShape>
    Inherited Members
    GraphStageWithMaterializedValue<TShape, NotUsed>.InitialAttributes
    GraphStageWithMaterializedValue<TShape, NotUsed>.Shape
    GraphStageWithMaterializedValue<TShape, NotUsed>.WithAttributes(Attributes)
    GraphStageWithMaterializedValue<TShape, NotUsed>.CreateLogicAndMaterializedValue(Attributes)
    GraphStageWithMaterializedValue<TShape, NotUsed>.Module
    GraphStageWithMaterializedValue<TShape, NotUsed>.AddAttributes(Attributes)
    GraphStageWithMaterializedValue<TShape, NotUsed>.Named(string)
    GraphStageWithMaterializedValue<TShape, NotUsed>.Async()
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.MemberwiseClone()
    object.ReferenceEquals(object, object)
    object.ToString()
    Namespace: Akka.Streams.Stage
    Assembly: Akka.Streams.dll
    Syntax
    public abstract class GraphStage<TShape> : GraphStageWithMaterializedValue<TShape, NotUsed>, IGraphStageWithMaterializedValue<TShape, NotUsed>, IGraph<TShape, NotUsed>, IGraph<TShape> where TShape : Shape
    Type Parameters
    Name Description
    TShape

    TBD

    Methods

    | Edit this page View Source

    CreateLogic(Attributes)

    TBD

    Declaration
    protected abstract GraphStageLogic CreateLogic(Attributes inheritedAttributes)
    Parameters
    Type Name Description
    Attributes inheritedAttributes

    TBD

    Returns
    Type Description
    GraphStageLogic

    TBD

    | Edit this page View Source

    CreateLogicAndMaterializedValue(Attributes)

    TBD

    Declaration
    public override sealed ILogicAndMaterializedValue<NotUsed> CreateLogicAndMaterializedValue(Attributes inheritedAttributes)
    Parameters
    Type Name Description
    Attributes inheritedAttributes

    TBD

    Returns
    Type Description
    ILogicAndMaterializedValue<NotUsed>

    TBD

    Overrides
    GraphStageWithMaterializedValue<TShape, NotUsed>.CreateLogicAndMaterializedValue(Attributes)

    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