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 anSinkRefin thetoSerializationFormat(akka.stream.SourceRef<T>).<T> SourceRef<T>resolveSourceRef(java.lang.String serializedSourceRef)Deserialize anSourceRefin thetoSerializationFormat(akka.stream.SourceRef<T>).<T> java.lang.StringtoSerializationFormat(SinkRef<T> ref)Generate full String representation of theSinkRef.<T> java.lang.StringtoSerializationFormat(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 anSourceRefin thetoSerializationFormat(akka.stream.SourceRef<T>).
-
resolveSinkRef
<T> SinkRef<T> resolveSinkRef(java.lang.String serializedSinkRef)
Deserialize anSinkRefin thetoSerializationFormat(akka.stream.SourceRef<T>).
-
-