Search Results for

    Show / Hide Table of Contents

    Interface ISourceQueue<T>

    This interface allows to have the queue as a data source for some stream.

    Namespace: Akka.Streams
    Assembly: Akka.Streams.dll
    Syntax
    public interface ISourceQueue<in T>
    Type Parameters
    Name Description
    T

    TBD

    Methods

    | Edit this page View Source

    OfferAsync(T)

    Method offers next element to a stream and returns task that:

    - competes with QueueOfferResult.Enqueued if element is consumed by a stream

    - competes with QueueOfferResult.Dropped when stream dropped offered element

    - competes with QueueOfferResult.QueueClosed when stream is completed while task is active

    - competes with QueueOfferResult.Failure when failure to enqueue element from upstream

    - fails if stream is completed or you cannot call offer in this moment because of implementation rules (like for backpressure mode and full buffer you need to wait for last offer call task completion.

    Declaration
    Task<IQueueOfferResult> OfferAsync(T element)
    Parameters
    Type Name Description
    T element

    element to send to a stream

    Returns
    Type Description
    Task<IQueueOfferResult>

    TBD

    | Edit this page View Source

    WatchCompletionAsync()

    Method returns Task that will be completed if the stream completes, or will be failed when the stage faces an internal failure.

    Declaration
    Task WatchCompletionAsync()
    Returns
    Type Description
    Task

    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