Package akka.stream
Interface SinkRef<In>
-
public interface SinkRef<In>
ASinkRef
allows sharing a "reference" to aSink
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
SinkRef
you have to materialize theSink
that you want to obtain a reference to by attaching it to aStreamRefs.sinkRef()
.Stream refs can be seen as Reactive Streams over network boundaries. See also
SourceRef
which is the dual of aSinkRef
.For additional configuration see
reference.conf
as well asStreamRefAttributes
.Not for user extension.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Sink<In,NotUsed>
getSink()
Java API: Getjavadsl.Sink
underlying to this source ref.Sink<In,NotUsed>
sink()
Scala API: GetSink
underlying to this source ref.
-