Search Results for

    Show / Hide Table of Contents

    Class StreamRefAttributes

    Attributes for stream refs (ISourceRef<TOut> and ISinkRef<TIn>). Note that more attributes defined in Attributes and ActorAttributes.

    Inheritance
    object
    StreamRefAttributes
    Inherited Members
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.MemberwiseClone()
    object.ReferenceEquals(object, object)
    object.ToString()
    Namespace: Akka.Streams
    Assembly: Akka.Streams.dll
    Syntax
    public static class StreamRefAttributes

    Methods

    | Edit this page View Source

    CreateBufferCapacity(int)

    Specifies the size of the buffer on the receiving side that is eagerly filled even without demand.

    Declaration
    public static Attributes CreateBufferCapacity(int capacity)
    Parameters
    Type Name Description
    int capacity
    Returns
    Type Description
    Attributes
    | Edit this page View Source

    CreateDemandRedeliveryInterval(TimeSpan)

    If no new elements arrive within this timeout, demand is redelivered.

    Declaration
    public static Attributes CreateDemandRedeliveryInterval(TimeSpan timeout)
    Parameters
    Type Name Description
    TimeSpan timeout
    Returns
    Type Description
    Attributes
    | Edit this page View Source

    CreateFinalTerminationSignalDeadline(TimeSpan)

    The time between the Terminated signal being received and when the local SourceRef determines to fail itself

    Declaration
    public static Attributes CreateFinalTerminationSignalDeadline(TimeSpan timeout)
    Parameters
    Type Name Description
    TimeSpan timeout
    Returns
    Type Description
    Attributes
    | Edit this page View Source

    CreateSubscriptionTimeout(TimeSpan)

    Specifies the subscription timeout within which the remote side MUST subscribe to the handed out stream reference.

    Declaration
    public static Attributes CreateSubscriptionTimeout(TimeSpan timeout)
    Parameters
    Type Name Description
    TimeSpan timeout
    Returns
    Type Description
    Attributes
    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