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
SourceRefyou have to materialize theSourcethat 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
SinkRefwhich is the dual of aSourceRef.For additional configuration see
reference.confas 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.Sourceunderlying to this source ref.Source<T,NotUsed>source()Scala API: GetSourceunderlying to this source ref.
-