Package akka.stream.scaladsl
Class StreamRefs
- java.lang.Object
-
- akka.stream.scaladsl.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 localSource
which materializes aSinkRef
which 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 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 directly in place of the local Sink.
-
-
-
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 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 localSource
which materializes aSinkRef
which 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
.
-
-