Package akka.stream.javadsl
Class StreamRefs
- java.lang.Object
-
- akka.stream.javadsl.StreamRefs
-
public class StreamRefs extends java.lang.Object
Factories 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 localSink
which materializes aSourceRef
which 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 localSink
which materializes aSourceRef
which 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 localSink
which materializes aSourceRef
which 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 localSink
which materializes aSourceRef
which 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
.
-
-