Package org.apache.pekko.stream
Interface StreamRefResolver
- All Superinterfaces:
Extension
The stream ref resolver provides a way to serialize and deserialize streamrefs in user serializers.
Not for user extension
-
Method Summary
Modifier and TypeMethodDescription<T> SinkRef<T>resolveSinkRef(String serializedSinkRef) Deserialize anSinkRefin thetoSerializationFormat(org.apache.pekko.stream.SourceRef<T>).<T> SourceRef<T>resolveSourceRef(String serializedSourceRef) Deserialize anSourceRefin thetoSerializationFormat(org.apache.pekko.stream.SourceRef<T>).<T> StringtoSerializationFormat(SinkRef<T> ref) Generate full String representation of theSinkRef.<T> StringtoSerializationFormat(SourceRef<T> ref) Generate full String representation of theSourceRef.
-
Method Details
-
toSerializationFormat
Generate full String representation of theSourceRef. This representation should be used as serialized representation. -
toSerializationFormat
Generate full String representation of theSinkRef. This representation should be used as serialized representation. -
resolveSourceRef
Deserialize anSourceRefin thetoSerializationFormat(org.apache.pekko.stream.SourceRef<T>). -
resolveSinkRef
Deserialize anSinkRefin thetoSerializationFormat(org.apache.pekko.stream.SourceRef<T>).
-