Interface ISinkRef<TIn>

A ISinkRef<TIn> allows sharing a "reference" to a Sink<TIn, TMat> with others, with the main purpose of crossing a network boundary. Usually obtaining a SinkRef would be done via Actor messaging, in which one system asks a remote one, to accept some data from it, and the remote one decides to accept the request to send data in a back-pressured streaming fashion -- using a sink ref.

To create a ISinkRef<TIn> you have to materialize the Sink that you want to obtain a reference to by attaching it to a SinkRef<T>().

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

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

Inherited Members
Namespace: Akka.Streams
Assembly: Akka.Streams.dll
Syntax
public interface ISinkRef<TIn> : ISurrogated
Type Parameters
Name Description
TIn

Properties

| Edit this page View Source

Sink

Declaration
Sink<TIn, NotUsed> Sink { get; }
Property Value
Type Description
Sink<TIn, NotUsed>

Extension Methods

See Also