Package akka.stream.scaladsl
Class StreamRefs
- java.lang.Object
-
- akka.stream.scaladsl.StreamRefs
-
public class StreamRefs extends java.lang.ObjectFactories for creating stream refs.
-
-
Constructor Summary
Constructors Constructor Description StreamRefs()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> Source<T,SinkRef<T>>sinkRef()A localSourcewhich materializes aSinkRefwhich can be used by other streams (including remote ones), to publish data to this local stream, as if they were attached directly in place of the local Source.static <T> Sink<T,SourceRef<T>>sourceRef()A localSinkwhich materializes aSourceRefwhich can be used by other streams (including remote ones), to consume data from this local stream, as if they were attached directly in place of the local Sink.
-
-
-
Method Detail
-
sourceRef
public static <T> Sink<T,SourceRef<T>> sourceRef()
A localSinkwhich materializes aSourceRefwhich can be used by other streams (including remote ones), to consume data from this local stream, as if they were attached directly in place of the local Sink.Adheres to
StreamRefAttributes.See more detailed documentation on
SourceRef.
-
sinkRef
public static <T> Source<T,SinkRef<T>> sinkRef()
A localSourcewhich materializes aSinkRefwhich can be used by other streams (including remote ones), to publish data to this local stream, as if they were attached directly in place of the local Source.Adheres to
StreamRefAttributes.See more detailed documentation on
SinkRef.
-
-