Package akka.stream
Interface StreamRefResolver
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description <T> SinkRef<T>
resolveSinkRef(java.lang.String serializedSinkRef)
Deserialize anSinkRef
in thetoSerializationFormat(akka.stream.SourceRef<T>)
.<T> SourceRef<T>
resolveSourceRef(java.lang.String serializedSourceRef)
Deserialize anSourceRef
in thetoSerializationFormat(akka.stream.SourceRef<T>)
.<T> java.lang.String
toSerializationFormat(SinkRef<T> ref)
Generate full String representation of theSinkRef
.<T> java.lang.String
toSerializationFormat(SourceRef<T> ref)
Generate full String representation of theSourceRef
.
-
-
-
Method Detail
-
toSerializationFormat
<T> java.lang.String toSerializationFormat(SourceRef<T> ref)
Generate full String representation of theSourceRef
. This representation should be used as serialized representation.
-
toSerializationFormat
<T> java.lang.String toSerializationFormat(SinkRef<T> ref)
Generate full String representation of theSinkRef
. This representation should be used as serialized representation.
-
resolveSourceRef
<T> SourceRef<T> resolveSourceRef(java.lang.String serializedSourceRef)
Deserialize anSourceRef
in thetoSerializationFormat(akka.stream.SourceRef<T>)
.
-
resolveSinkRef
<T> SinkRef<T> resolveSinkRef(java.lang.String serializedSinkRef)
Deserialize anSinkRef
in thetoSerializationFormat(akka.stream.SourceRef<T>)
.
-
-