Search Results for

    Show / Hide Table of Contents

    Interface ISourceRef<TOut>

    A SourceRef allows sharing a "reference" with others, with the main purpose of crossing a network boundary. Usually obtaining a SourceRef would be done via Actor messaging, in which one system asks a remote one, to share some data with it, and the remote one decides to do so in a back-pressured streaming fashion -- using a stream ref.

    To create a ISourceRef<TOut> you have to materialize the Source that you want to obtain a reference to by attaching it to a SourceRef<T>().

    Stream refs can be seen as Reactive Streams over network boundaries.

    For additional configuration see reference.conf as well as StreamRefAttributes.

    Inherited Members
    ISurrogated.ToSurrogate(ActorSystem)
    Namespace: Akka.Streams
    Assembly: Akka.Streams.dll
    Syntax
    public interface ISourceRef<TOut> : ISurrogated
    Type Parameters
    Name Description
    TOut

    Properties

    | Edit this page View Source

    Source

    Declaration
    Source<TOut, NotUsed> Source { get; }
    Property Value
    Type Description
    Source<TOut, NotUsed>

    Extension Methods

    ObjectExtensions.IsDefaultForType<T>(T)
    ObjectExtensions.AsOption<T>(T)
    Extensions.AsInstanceOf<T>(object)

    See Also

    ISinkRef<TIn>
    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