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
SourceRefyou have to materialize the
Sourcethat you want to obtain a reference to by attaching it to a
Stream refs can be seen as Reactive Streams over network boundaries. See also
SinkRefwhich is the dual of a
For additional configuration see
reference.confas well as
Not for user extension.
All Methods Instance Methods Abstract Methods Modifier and Type Method Description
getSource()Java API: Get
javadsl.Sourceunderlying to this source ref.
source()Scala API: Get
Sourceunderlying to this source ref.