Package akka.stream.javadsl
Class StreamRefs
- java.lang.Object
-
- akka.stream.javadsl.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 localSinkwhich materializes aSourceRefwhich can be used by other streams (including remote ones), to consume data from this local stream, as if they were attached in the spot of the local Sink directly.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 in the spot of the local Sink directly.
-
-
-
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 in the spot of the local Sink directly.Adheres to
StreamRefAttributes.See more detailed documentation on
SourceRef.
-
sinkRef
public static <T> Source<T,SinkRef<T>> sinkRef()
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 in the spot of the local Sink directly.Adheres to
StreamRefAttributes.See more detailed documentation on
SinkRef.
-
-