Package akka.stream.scaladsl
Class StreamRefs$
- java.lang.Object
-
- akka.stream.scaladsl.StreamRefs$
-
public class StreamRefs$ extends java.lang.ObjectA 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.
-
-
Field Summary
Fields Modifier and Type Field Description static StreamRefs$MODULE$Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description StreamRefs$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> Source<T,scala.concurrent.Future<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.<T> Sink<T,scala.concurrent.Future<SourceRef<T>>>sourceRef()
-
-
-
Field Detail
-
MODULE$
public static final StreamRefs$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
sinkRef
public <T> Source<T,scala.concurrent.Future<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.- Returns:
- (undocumented)
-
-