Package akka.stream
Interface SourceRef<T>
-
public interface SourceRef<T>
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
SourceRef
you have to materialize theSource
that you want to obtain a reference to by attaching it to aSink.sourceRef
.Stream refs can be seen as Reactive Streams over network boundaries. See also
SinkRef
which is the dual of aSourceRef
.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 Source<T,NotUsed>
getSource()
Java API: Getjavadsl.Source
underlying to this source ref.Source<T,NotUsed>
source()
Scala API: GetSource
underlying to this source ref.
-